diff --git a/server/src/main/java/io/druid/segment/realtime/RealtimeManager.java b/server/src/main/java/io/druid/segment/realtime/RealtimeManager.java index 87c8328ebba..2a1f0679841 100644 --- a/server/src/main/java/io/druid/segment/realtime/RealtimeManager.java +++ b/server/src/main/java/io/druid/segment/realtime/RealtimeManager.java @@ -104,7 +104,13 @@ public class RealtimeManager implements QuerySegmentWalker } chiefs.add(chief); - chief.setName(String.format("chief-%s", schema.getDataSource())); + chief.setName( + String.format( + "chief-%s[%s]", + schema.getDataSource(), + fireDepartment.getTuningConfig().getShardSpec().getPartitionNum() + ) + ); chief.setDaemon(true); chief.init(); chief.start();