diff --git a/lib/fluent/plugin/output.rb b/lib/fluent/plugin/output.rb index b2e5b1c94f..40f827cf7d 100644 --- a/lib/fluent/plugin/output.rb +++ b/lib/fluent/plugin/output.rb @@ -629,7 +629,7 @@ def get_worker_lock_if_need(name) def get_flush_thread_lock_if_need need_thread_lock = actual_flush_thread_count > 1 if need_thread_lock - @flush_thread_mutex.synchronize { yeild } + @flush_thread_mutex.synchronize { yield } else yield end