From 5aca824768b66ca2a29b77ac13fd0b55f92c491b Mon Sep 17 00:00:00 2001 From: Joseph Date: Fri, 23 Sep 2022 20:43:43 +0800 Subject: [PATCH] koord-scheduler: fix PodGroupController panic when init (#659) Signed-off-by: Joseph --- .../plugins/coscheduling/controller/podgroup.go | 17 ++++++++--------- 1 file changed, 8 insertions(+), 9 deletions(-) diff --git a/pkg/scheduler/plugins/coscheduling/controller/podgroup.go b/pkg/scheduler/plugins/coscheduling/controller/podgroup.go index 300a91310..58b619df8 100644 --- a/pkg/scheduler/plugins/coscheduling/controller/podgroup.go +++ b/pkg/scheduler/plugins/coscheduling/controller/podgroup.go @@ -69,9 +69,14 @@ func NewPodGroupController(client kubernetes.Interface, pgClient schedclientset.Interface, podGroupManager *core.PodGroupManager, recorder events.EventRecorder) *PodGroupController { ctrl := &PodGroupController{ - eventRecorder: recorder, - pgQueue: workqueue.NewNamedRateLimitingQueue(workqueue.DefaultControllerRateLimiter(), "PodGroup"), - pgManager: podGroupManager, + eventRecorder: recorder, + pgManager: podGroupManager, + pgClient: pgClient, + pgLister: pgInformer.Lister(), + podLister: podInformer.Lister(), + pgListerSynced: pgInformer.Informer().HasSynced, + podListerSynced: podInformer.Informer().HasSynced, + pgQueue: workqueue.NewNamedRateLimitingQueue(workqueue.DefaultControllerRateLimiter(), "PodGroup"), } pgInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ @@ -83,12 +88,6 @@ func NewPodGroupController(client kubernetes.Interface, AddFunc: ctrl.podAdded, UpdateFunc: ctrl.podUpdated, }) - - ctrl.pgLister = pgInformer.Lister() - ctrl.podLister = podInformer.Lister() - ctrl.pgListerSynced = pgInformer.Informer().HasSynced - ctrl.podListerSynced = podInformer.Informer().HasSynced - ctrl.pgClient = pgClient return ctrl }