Apply feedback from ashie on GitHub#3808

Signed-off-by: Fujimoto Seiji <[email protected]>
fluent · Jul 1, 2022 · 0a7a590 · 0a7a590
1 parent 2ebce28
commit 0a7a590
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/lib/fluent/plugin/base.rb b/lib/fluent/plugin/base.rb
@@ -34,6 +34,7 @@ def initialize
         @_state = State.new(false, false, false, false, false, false, false, false, false)
         @_context_router = nil
         @_fluentd_worker_id = nil
+        @_fluentd_lockdir = nil
         @under_plugin_development = false
       end
 
@@ -74,7 +75,7 @@ def multi_workers_ready?
         true
       end
 
-      def acquire_worker_lock(name, &block)
+      def acquire_worker_lock(name)
         if fluentd_lockdir.nil?
           raise InvalidLockDirectory, "can't acquire lock because FLUENTD_LOCKDIR isn't set"
         end