diff --git a/pkg/clustercache/controller.go b/pkg/clustercache/controller.go index f879323d6..3884800d7 100644 --- a/pkg/clustercache/controller.go +++ b/pkg/clustercache/controller.go @@ -216,6 +216,7 @@ func (h *clusterCache) List(gvr schema2.GroupVersionResource) []interface{} { } func (h *clusterCache) start() { + defer h.workqueue.ShutDown() for { eventObj, ok := h.workqueue.Get() if ok { @@ -247,6 +248,7 @@ func (h *clusterCache) start() { logrus.Errorf("failed to handle remove event: %v", err) } } + h.workqueue.Done(eventObj) } }