From 33360c57e5bba63cf0833afc0a3ff65dc148667b Mon Sep 17 00:00:00 2001 From: gj199575 <409237405@qq.com> Date: Fri, 14 Jul 2023 16:45:21 +0800 Subject: [PATCH] =?UTF-8?q?=E5=92=8Cdescheduler=20=E8=81=94=E5=8A=A8?= =?UTF-8?q?=E8=BF=9B=E8=A1=8C=E5=AE=89=E5=85=A8=E9=87=8D=E8=B0=83=E5=8F=96?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Signed-off-by: gj199575 <409237405@qq.com> --- pkg/scheduler/cache/cache.go | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) 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{