Reset/flush saved contents from bad metric (influxdata#4646)

otherpirate · Mar 15, 2019 · 91c26a6 · 91c26a6
1 parent 21a351d
commit 91c26a6
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/plugins/parsers/influx/parser.go b/plugins/parsers/influx/parser.go
@@ -63,6 +63,7 @@ func (p *Parser) Parse(input []byte) ([]telegraf.Metric, error) {
 	for p.machine.ParseLine() {
 		err := p.machine.Err()
 		if err != nil {
+			p.handler.Reset()
 			return nil, &ParseError{
 				Offset: p.machine.Position(),
 				msg:    err.Error(),