diff --git a/.changelog/15134.txt b/.changelog/15134.txt new file mode 100644 index 000000000..3e4f358e7 --- /dev/null +++ b/.changelog/15134.txt @@ -0,0 +1,3 @@ +```release-note:bug +cleanup: fixed missing timer.Reset for plan queue stat emitter +``` \ No newline at end of file diff --git a/nomad/plan_queue.go b/nomad/plan_queue.go index 2ba35e068..0c1cb554a 100644 --- a/nomad/plan_queue.go +++ b/nomad/plan_queue.go @@ -201,6 +201,8 @@ func (q *PlanQueue) EmitStats(period time.Duration, stopCh <-chan struct{}) { defer stop() for { + timer.Reset(period) + select { case <-timer.C: stats := q.Stats()