ml: clear last recently used parser to match next parser(#5524)

Signed-off-by: Takahiro Yamashita <nokute78@gmail.com>
fluent · Jul 6, 2022 · 97d50c3 · 97d50c3
1 parent 96aaa59
commit 97d50c3
Showing 1 changed file with 10 additions and 6 deletions.
diff --git a/src/multiline/flb_ml.c b/src/multiline/flb_ml.c
@@ -709,9 +709,11 @@ int flb_ml_append(struct flb_ml *ml, uint64_t stream_id,
             }
         }
         else if (lru_parser && lru_parser->last_stream_id > 0) {
-            flb_ml_flush_parser_instance(ml,
-                                         lru_parser,
-                                         lru_parser->last_stream_id);
+            /*
+             * Clear last recently used parser to match new parser.
+             * Do not flush last_stream_id since it should continue to parsing.
+             */
+            lru_parser = NULL;
         }
     }
 
@@ -819,9 +821,11 @@ int flb_ml_append_object(struct flb_ml *ml, uint64_t stream_id,
             }
         }
         else if (lru_parser && lru_parser->last_stream_id > 0) {
-            flb_ml_flush_parser_instance(ml,
-                                         lru_parser,
-                                         lru_parser->last_stream_id);
+            /*
+             * Clear last recently used parser to match new parser.
+             * Do not flush last_stream_id since it should continue to parsing.
+             */
+            lru_parser = NULL;
         }
     }