Add missing timer reset (#15134)
This commit is contained in:
parent
654ae1d591
commit
83e43e01c1
|
@ -0,0 +1,3 @@
|
|||
```release-note:bug
|
||||
cleanup: fixed missing timer.Reset for plan queue stat emitter
|
||||
```
|
|
@ -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()
|
||||
|
|
Loading…
Reference in New Issue