lib/fluent/plugin/in_tail.rb in fluentd-0.10.24 vs lib/fluent/plugin/in_tail.rb in fluentd-0.10.25
- old
+ new
@@ -88,10 +88,10 @@
def receive_lines(lines)
es = MultiEventStream.new
lines.each {|line|
begin
- line.rstrip! # remove \n
+ line.chomp! # remove \n
time, record = parse_line(line)
if time && record
es.add(time, record)
end
rescue