diff --git a/pkg/controller/disruption/disruption.go b/pkg/controller/disruption/disruption.go index a11f267262e4e..31a7228d4f5eb 100644 --- a/pkg/controller/disruption/disruption.go +++ b/pkg/controller/disruption/disruption.go @@ -648,7 +648,7 @@ func (dc *DisruptionController) processNextStalePodDisruptionWorkItem(ctx contex defer dc.stalePodDisruptionQueue.Done(key) err := dc.syncStalePodDisruption(ctx, key.(string)) if err == nil { - dc.queue.Forget(key) + dc.stalePodDisruptionQueue.Forget(key) return true } utilruntime.HandleError(fmt.Errorf("error syncing Pod %v to clear DisruptionTarget condition, requeueing: %v", key.(string), err))