diff --git a/pkg/scheduler/core/scheduling_queue.go b/pkg/scheduler/core/scheduling_queue.go index a49dbb9e9d..3c87aa246e 100644 --- a/pkg/scheduler/core/scheduling_queue.go +++ b/pkg/scheduler/core/scheduling_queue.go @@ -267,7 +267,7 @@ func (p *PriorityQueue) AddIfNotPresent(pod *v1.Pod) error { } err := p.activeQ.Add(pod) if err != nil { - glog.Errorf("Error adding pod %v to the scheduling queue: %v", pod.Name, err) + glog.Errorf("Error adding pod %v/%v to the scheduling queue: %v", pod.Namespace, pod.Name, err) } else { p.addNominatedPodIfNeeded(pod) p.cond.Broadcast() @@ -410,7 +410,7 @@ func (p *PriorityQueue) MoveAllToActiveQueue() { defer p.lock.Unlock() for _, pod := range p.unschedulableQ.pods { if err := p.activeQ.Add(pod); err != nil { - glog.Errorf("Error adding pod %v to the scheduling queue: %v", pod.Name, err) + glog.Errorf("Error adding pod %v/%v to the scheduling queue: %v", pod.Namespace, pod.Name, err) } } p.unschedulableQ.clear() @@ -425,7 +425,7 @@ func (p *PriorityQueue) movePodsToActiveQueue(pods []*v1.Pod) { if err := p.activeQ.Add(pod); err == nil { p.unschedulableQ.delete(pod) } else { - glog.Errorf("Error adding pod %v to the scheduling queue: %v", pod.Name, err) + glog.Errorf("Error adding pod %v/%v to the scheduling queue: %v", pod.Namespace, pod.Name, err) } } p.receivedMoveRequest = true diff --git a/pkg/scheduler/factory/factory.go b/pkg/scheduler/factory/factory.go index 00cb9453c5..e65ed29bcc 100644 --- a/pkg/scheduler/factory/factory.go +++ b/pkg/scheduler/factory/factory.go @@ -1191,7 +1191,7 @@ func (c *configFactory) getPluginArgs() (*PluginFactoryArgs, error) { func (c *configFactory) getNextPod() *v1.Pod { pod, err := c.podQueue.Pop() if err == nil { - glog.V(4).Infof("About to try and schedule pod %v", pod.Name) + glog.V(4).Infof("About to try and schedule pod %v/%v", pod.Namespace, pod.Name) return pod } glog.Errorf("Error while retrieving next pod from scheduling queue: %v", err) diff --git a/pkg/scheduler/scheduler.go b/pkg/scheduler/scheduler.go index 8e6fc61ae0..fe66270215 100644 --- a/pkg/scheduler/scheduler.go +++ b/pkg/scheduler/scheduler.go @@ -232,7 +232,7 @@ func (sched *Scheduler) preempt(preemptor *v1.Pod, scheduleErr error) (string, e nodeName = node.Name err = sched.config.PodPreemptor.SetNominatedNodeName(preemptor, nodeName) if err != nil { - glog.Errorf("Error in preemption process. Cannot update pod %v annotations: %v", preemptor.Name, err) + glog.Errorf("Error in preemption process. Cannot update pod %v/%v annotations: %v", preemptor.Namespace, preemptor.Name, err) return "", err } for _, victim := range victims {