Fix tags applied to wrong metric on parse error (influxdata#5650)

bearstech · Apr 17, 2020 · 429c1ae · 429c1ae
1 parent ef914a8
commit 429c1ae
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 0 deletions.
diff --git a/plugins/parsers/influx/handler.go b/plugins/parsers/influx/handler.go
@@ -118,3 +118,7 @@ func (h *MetricHandler) SetTimestamp(tm []byte) error {
 	h.builder.SetTime(time.Unix(0, ns))
 	return nil
 }
+
+func (h *MetricHandler) Reset() {
+	h.builder.Reset()
+}
diff --git a/plugins/parsers/influx/parser.go b/plugins/parsers/influx/parser.go
@@ -75,6 +75,7 @@ func (p *Parser) Parse(input []byte) ([]telegraf.Metric, error) {
 		}
 
 		if err != nil {
+			p.handler.Reset()
 			return nil, &ParseError{
 				Offset:     p.machine.Position(),
 				LineOffset: p.machine.LineOffset(),
@@ -87,6 +88,7 @@ func (p *Parser) Parse(input []byte) ([]telegraf.Metric, error) {
 
 		metric, err := p.handler.Metric()
 		if err != nil {
+			p.handler.Reset()
 			return nil, err
 		}