diff --git a/pkg/scheduler/factory.go b/pkg/scheduler/factory.go index e2db4e43ad2..1979e80c442 100644 --- a/pkg/scheduler/factory.go +++ b/pkg/scheduler/factory.go @@ -445,9 +445,9 @@ func MakeDefaultErrorFunc(client clientset.Interface, podLister corelisters.PodL return func(podInfo *framework.QueuedPodInfo, err error) { pod := podInfo.Pod if err == core.ErrNoNodesAvailable { - klog.V(2).Infof("Unable to schedule %v/%v: no nodes are registered to the cluster; waiting", pod.Namespace, pod.Name) + klog.V(2).InfoS("Unable to schedule pod; no nodes are registered to the cluster; waiting", "pod", klog.KObj(pod)) } else if _, ok := err.(*core.FitError); ok { - klog.V(2).Infof("Unable to schedule %v/%v: no fit: %v; waiting", pod.Namespace, pod.Name, err) + klog.V(2).InfoS("Unable to schedule pod; no fit; waiting", "pod", klog.KObj(pod), "err", err) } else if apierrors.IsNotFound(err) { klog.V(2).Infof("Unable to schedule %v/%v: possibly due to node not found: %v; waiting", pod.Namespace, pod.Name, err) if errStatus, ok := err.(apierrors.APIStatus); ok && errStatus.Status().Details.Kind == "node" { @@ -463,7 +463,7 @@ func MakeDefaultErrorFunc(client clientset.Interface, podLister corelisters.PodL } } } else { - klog.Errorf("Error scheduling %v/%v: %v; retrying", pod.Namespace, pod.Name, err) + klog.ErrorS(err, "Error scheduling pod; retrying", "pod", klog.KObj(pod)) } // Check if the Pod exists in informer cache. diff --git a/pkg/scheduler/scheduler.go b/pkg/scheduler/scheduler.go index e2df50b4c67..dfbd06a5d8c 100644 --- a/pkg/scheduler/scheduler.go +++ b/pkg/scheduler/scheduler.go @@ -570,7 +570,7 @@ func (sched *Scheduler) scheduleOne(ctx context.Context) { // No nodes available is counted as unschedulable rather than an error. metrics.PodScheduleFailures.Inc() } else { - klog.Errorf("error selecting node for pod: %v", err) + klog.ErrorS(err, "Error selecting node for pod", "pod", klog.KObj(pod)) metrics.PodScheduleErrors.Inc() } sched.recordSchedulingFailure(prof, podInfo, err, v1.PodReasonUnschedulable, nominatedNode) @@ -675,7 +675,7 @@ func (sched *Scheduler) scheduleOne(ctx context.Context) { } else { // Calculating nodeResourceString can be heavy. Avoid it if klog verbosity is below 2. if klog.V(2).Enabled() { - klog.Infof("pod %v/%v is bound successfully on node %q, %d nodes evaluated, %d nodes were found feasible.", assumedPod.Namespace, assumedPod.Name, scheduleResult.SuggestedHost, scheduleResult.EvaluatedNodes, scheduleResult.FeasibleNodes) + klog.InfoS("Successfully bound pod to node", "pod", klog.KObj(pod), "node", scheduleResult.SuggestedHost, "evaluatedNodes", scheduleResult.EvaluatedNodes, "feasibleNodes", scheduleResult.FeasibleNodes) } metrics.PodScheduleSuccesses.Inc()