fix nodeInformer cache

fighterhit · Jun 2, 2021 · ec6b982 · ec6b982
1 parent 573ec23
commit ec6b982
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/pkg/descheduler/descheduler.go b/pkg/descheduler/descheduler.go
@@ -20,7 +20,7 @@ import (
 	"context"
 	"fmt"
 
-	"k8s.io/api/core/v1"
+	v1 "k8s.io/api/core/v1"
 	"k8s.io/apimachinery/pkg/util/wait"
 	"k8s.io/client-go/informers"
 	clientset "k8s.io/client-go/kubernetes"
@@ -72,6 +72,8 @@ type strategyFunction func(ctx context.Context, client clientset.Interface, stra
 func RunDeschedulerStrategies(ctx context.Context, rs *options.DeschedulerServer, deschedulerPolicy *api.DeschedulerPolicy, evictionPolicyGroupVersion string, stopChannel chan struct{}) error {
 	sharedInformerFactory := informers.NewSharedInformerFactory(rs.Client, 0)
 	nodeInformer := sharedInformerFactory.Core().V1().Nodes()
+	// just trigger sharedInformerFactory add node informers
+	nodeInformer.Informer()
 
 	sharedInformerFactory.Start(stopChannel)
 	sharedInformerFactory.WaitForCacheSync(stopChannel)