diff --git a/lib/fluent/supervisor.rb b/lib/fluent/supervisor.rb index 5b22e00e59..0bc2d5f317 100644 --- a/lib/fluent/supervisor.rb +++ b/lib/fluent/supervisor.rb @@ -716,7 +716,13 @@ def logging_with_console_output end def main_process(&block) - Process.setproctitle("worker:#{@process_name}") if @process_name + if @process_name + if @workers > 1 + Process.setproctitle("worker:#{@process_name}#{ENV['SERVERENGINE_WORKER_ID']}") + else + Process.setproctitle("worker:#{@process_name}") + end + end unrecoverable_error = false