lib/fluent/plugin/in_tail.rb in fluentd-0.10.46 vs lib/fluent/plugin/in_tail.rb in fluentd-0.10.47
- old
+ new
@@ -186,10 +186,10 @@
if lb = tw.line_buffer
lb.chomp!
time, record = parse_line(lb)
if time && record
tag = if @tag_prefix || @tag_suffix
- @tag_prefix + tail_watcher.tag + @tag_suffix
+ @tag_prefix + tw.tag + @tag_suffix
else
@tag
end
Engine.emit(tag, time, record)
else