diff --git a/plugins/inputs/statsd/statsd.go b/plugins/inputs/statsd/statsd.go index e1b6e837c3847..168d4b9cf4309 100644 --- a/plugins/inputs/statsd/statsd.go +++ b/plugins/inputs/statsd/statsd.go @@ -712,6 +712,8 @@ func (s *Statsd) parseStatsdLine(line string) error { // map of tags. // Return values are (, , ) func (s *Statsd) parseName(bucket string) (string, string, map[string]string) { + s.Lock() + defer s.Unlock() tags := make(map[string]string) bucketparts := strings.Split(bucket, ",")