diff --git a/pkg/scheduler/cache/cache.go b/pkg/scheduler/cache/cache.go index a311471c439..233d1f2547e 100644 --- a/pkg/scheduler/cache/cache.go +++ b/pkg/scheduler/cache/cache.go @@ -161,7 +161,12 @@ func (db *DefaultBinder) Bind(kubeClient kubernetes.Interface, tasks []*scheduli var errTasks []*schedulingapi.TaskInfo for _, task := range tasks { p := task.Pod - if err := kubeClient.CoreV1().Pods(p.Namespace).Bind(context.TODO(), + if p.Annotations["is-fake"] == "true" { + p.Annotations["fake-pod"] = task.NodeName + p.Spec.NodeName = "" + update, err := kubeClient.CoreV1().Pods(p.Namespace).Update(context.TODO(), p, metav1.UpdateOptions{}) + klog.Info(update, err) + } else if err := kubeClient.CoreV1().Pods(p.Namespace).Bind(context.TODO(), &v1.Binding{ ObjectMeta: metav1.ObjectMeta{Namespace: p.Namespace, Name: p.Name, UID: p.UID, Annotations: p.Annotations}, Target: v1.ObjectReference{