Call ticker.Stop() when aggregator is stopped

DataDog · Nov 24, 2022 · 47827df · 47827df
1 parent 6391269
commit 47827df
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/statsd/aggregator.go b/statsd/aggregator.go
@@ -66,6 +66,7 @@ func (a *aggregator) start(flushInterval time.Duration) {
 			case <-ticker.C:
 				a.flush()
 			case <-a.closed:
+				ticker.Stop()
 				return
 			}
 		}