diff --git a/lib/fluent/plugin/parser_ltsv.rb b/lib/fluent/plugin/parser_ltsv.rb index 13cb8f7fed..e5433d29ca 100644 --- a/lib/fluent/plugin/parser_ltsv.rb +++ b/lib/fluent/plugin/parser_ltsv.rb @@ -38,10 +38,8 @@ def configure(conf) def parse(text) r = {} text.split(@delimiter).each do |pair| - if pair.include? @label_delimiter - key, value = pair.split(@label_delimiter, 2) - r[key] = value - end + key, value = pair.split(@label_delimiter, 2) + r[key] = value if value end time, record = convert_values(parse_time(r), r) yield time, record