diff --git a/statsd/aggregator.go b/statsd/aggregator.go index 65c050ed..ae4723c4 100644 --- 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 } }