From 938b5f82620286e13077d017d492ce409e0453fc Mon Sep 17 00:00:00 2001 From: googs1025 Date: Tue, 11 Feb 2025 13:11:43 +0800 Subject: [PATCH] chore(scheduler): add more log info when no preemption candidates is found in preemption --- pkg/scheduler/framework/preemption/preemption.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/pkg/scheduler/framework/preemption/preemption.go b/pkg/scheduler/framework/preemption/preemption.go index 3b5c8daff41..070b6ef3672 100644 --- a/pkg/scheduler/framework/preemption/preemption.go +++ b/pkg/scheduler/framework/preemption/preemption.go @@ -40,7 +40,6 @@ import ( apipod "k8s.io/kubernetes/pkg/api/v1/pod" "k8s.io/kubernetes/pkg/scheduler/framework" "k8s.io/kubernetes/pkg/scheduler/framework/parallelize" - "k8s.io/kubernetes/pkg/scheduler/framework/plugins/names" "k8s.io/kubernetes/pkg/scheduler/metrics" "k8s.io/kubernetes/pkg/scheduler/util" ) @@ -149,7 +148,7 @@ func NewEvaluator(pluginName string, fh framework.Handle, i Interface, enableAsy pdbLister := fh.SharedInformerFactory().Policy().V1().PodDisruptionBudgets().Lister() ev := &Evaluator{ - PluginName: names.DefaultPreemption, + PluginName: pluginName, Handler: fh, PodLister: podLister, PdbLister: pdbLister, @@ -261,6 +260,7 @@ func (ev *Evaluator) Preempt(ctx context.Context, state *framework.CycleState, p // Return a FitError only when there are no candidates that fit the pod. if len(candidates) == 0 { + logger.V(2).Info("No preemption candidate is found; preemption is not helpful for scheduling", "pod", klog.KObj(pod)) fitError := &framework.FitError{ Pod: pod, NumAllNodes: len(allNodes),