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

rgitzel · Oct 17, 2018 · bdccea5 · bdccea5
1 parent ea6ae36
commit bdccea5
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(),