lib/fluent/plugin/in_http.rb in fluentd-0.10.36 vs lib/fluent/plugin/in_http.rb in fluentd-0.10.37
- old
+ new
@@ -115,9 +115,14 @@
else
raise "'json' or 'msgpack' parameter is required"
end
+ # Skip nil record
+ if record.nil?
+ return ["200 OK", {'Content-type'=>'text/plain'}, ""]
+ end
+
time = params['time']
time = time.to_i
if time == 0
time = Engine.now
end