diff --git a/src/multiline/flb_ml.c b/src/multiline/flb_ml.c index 5521f4f116c..befc2a42ca1 100644 --- a/src/multiline/flb_ml.c +++ b/src/multiline/flb_ml.c @@ -712,6 +712,8 @@ int flb_ml_append(struct flb_ml *ml, uint64_t stream_id, flb_ml_flush_parser_instance(ml, lru_parser, lru_parser->last_stream_id); + /* clear last recently used parser to match new parser */ + lru_parser = NULL; } } @@ -822,6 +824,8 @@ int flb_ml_append_object(struct flb_ml *ml, uint64_t stream_id, flb_ml_flush_parser_instance(ml, lru_parser, lru_parser->last_stream_id); + /* clear last recently used parser to match new parser */ + lru_parser = NULL; } }