diff --git a/pkg/controller/disruption/disruption.go b/pkg/controller/disruption/disruption.go index 1ad58e5205..1658d51560 100644 --- a/pkg/controller/disruption/disruption.go +++ b/pkg/controller/disruption/disruption.go @@ -119,7 +119,7 @@ func NewDisruptionController( dc := &DisruptionController{ kubeClient: kubeClient, queue: workqueue.NewNamedRateLimitingQueue(workqueue.DefaultControllerRateLimiter(), "disruption"), - recheckQueue: workqueue.NewNamedDelayingQueue("disruption-recheck"), + recheckQueue: workqueue.NewNamedDelayingQueue("disruption_recheck"), broadcaster: record.NewBroadcaster(), } dc.recorder = dc.broadcaster.NewRecorder(scheme.Scheme, v1.EventSource{Component: "controllermanager"})