diff --git a/lib/fluent/plugin/filter_parser.rb b/lib/fluent/plugin/filter_parser.rb index e9c03fd944..f15c8568ec 100644 --- a/lib/fluent/plugin/filter_parser.rb +++ b/lib/fluent/plugin/filter_parser.rb @@ -79,6 +79,10 @@ def filter_with_time(tag, time, record) end @accessor.delete(record) if @remove_key_name_field r = handle_parsed(tag, record, t, values) + # Note: If the parser returns multiple records from one raw_value, + # this returns only the first one record. + # Essentially, we should use `yield` here, but it is difficult with + # the current Filter structure. return t, r else if @emit_invalid_record_to_error