Ensure workers to 1 when target_worker_ids nil or false

Signed-off-by: Hiroshi Hatake <[email protected]>
fluent · Feb 21, 2019 · 44b67c9 · 44b67c9
1 parent 44f206a
commit 44b67c9
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/lib/fluent/plugin/base.rb b/lib/fluent/plugin/base.rb
@@ -52,7 +52,11 @@ def fluentd_worker_id
 
       def configure(conf)
         if conf.respond_to?(:for_this_worker?) && conf.for_this_worker?
-          workers = conf.target_worker_ids.size || 1
+          workers = if conf.target_worker_ids && !conf.target_worker_ids.empty?
+                      conf.target_worker_ids.size
+                    else
+                      1
+                    end
           system_config_override(workers: workers)
         end
         super