lib/fluent/plugin/in_gcloud_pubsub.rb in fluent-plugin-gcloud-pubsub-custom-0.1.0 vs lib/fluent/plugin/in_gcloud_pubsub.rb in fluent-plugin-gcloud-pubsub-custom-0.1.1
- old
+ new
@@ -80,10 +80,10 @@
end
es
end
def convert_line_to_event(line, es)
- line.chomp! # remove \n
+ line = line.chomp # remove \n
@parser.parse(line) { |time, record|
if time && record
es.add(time, record)
else
log.warn "pattern not match: #{line.inspect}"