lib/fluent/engine.rb in fluentd-0.10.12 vs lib/fluent/engine.rb in fluentd-0.10.13
- old
+ new
@@ -189,10 +189,10 @@
begin
if m.is_a?(Match)
m = m.output
end
if m.is_a?(BufferedOutput)
- m.try_flush
+ m.force_flush
elsif m.is_a?(MultiOutput)
flush_recursive(m.outputs)
end
rescue
$log.debug "error while force flushing", :error=>$!.to_s