From c3bfb568f978c3dbe96ea465d2b5ceebd2b9c01d Mon Sep 17 00:00:00 2001 From: duc <1025434218@qq.com> Date: Thu, 27 Jan 2022 17:08:12 +0800 Subject: [PATCH] fix flushBackoffQCompleted: remove defer 'defer' is called in the 'for' loop, remove it --- pkg/scheduler/internal/queue/scheduling_queue.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pkg/scheduler/internal/queue/scheduling_queue.go b/pkg/scheduler/internal/queue/scheduling_queue.go index 6200dc801a3..095129ccd60 100644 --- a/pkg/scheduler/internal/queue/scheduling_queue.go +++ b/pkg/scheduler/internal/queue/scheduling_queue.go @@ -428,7 +428,7 @@ func (p *PriorityQueue) flushBackoffQCompleted() { } p.activeQ.Add(rawPodInfo) metrics.SchedulerQueueIncomingPods.WithLabelValues("active", BackoffComplete).Inc() - defer p.cond.Broadcast() + p.cond.Broadcast() } }