diff --git a/pkg/scheduler/scheduler.go b/pkg/scheduler/scheduler.go index 0cbc50d6840..beeb61a919b 100644 --- a/pkg/scheduler/scheduler.go +++ b/pkg/scheduler/scheduler.go @@ -412,7 +412,7 @@ func (sched *Scheduler) preempt(ctx context.Context, prof *profile.Profile, stat // Make a call to update nominated node name of the pod on the API server. err = sched.podPreemptor.setNominatedNodeName(preemptor, nodeName) if err != nil { - klog.Errorf("Error in preemption process. Cannot set 'NominatedPod' on pod %v/%v: %v", preemptor.Namespace, preemptor.Name, err) + klog.Errorf("Error in preemption process. Cannot set 'NominatedNodeName' on pod %v/%v: %v", preemptor.Namespace, preemptor.Name, err) sched.SchedulingQueue.DeleteNominatedPodIfExists(preemptor) return "", err } @@ -435,11 +435,11 @@ func (sched *Scheduler) preempt(ctx context.Context, prof *profile.Profile, stat // be nil when a pod with nominated node name is eligible to preempt again, // but preemption logic does not find any node for it. In that case Preempt() // function of generic_scheduler.go returns the pod itself for removal of - // the 'NominatedPod' field. + // the 'NominatedNodeName' field. for _, p := range nominatedPodsToClear { rErr := sched.podPreemptor.removeNominatedNodeName(p) if rErr != nil { - klog.Errorf("Cannot remove 'NominatedPod' field of pod: %v", rErr) + klog.Errorf("Cannot remove 'NominatedNodeName' field of pod: %v", rErr) // We do not return as this error is not critical. } }