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