diff --git a/server/src/main/java/io/druid/server/coordinator/DruidCoordinator.java b/server/src/main/java/io/druid/server/coordinator/DruidCoordinator.java index 4ca6333b3d38..ebee431345e3 100644 --- a/server/src/main/java/io/druid/server/coordinator/DruidCoordinator.java +++ b/server/src/main/java/io/druid/server/coordinator/DruidCoordinator.java @@ -88,7 +88,6 @@ import java.util.Set; import java.util.concurrent.Callable; import java.util.concurrent.ConcurrentMap; -import java.util.concurrent.Executors; import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.atomic.AtomicReference; @@ -701,8 +700,10 @@ public void run() } } - balancerExec = MoreExecutors.listeningDecorator( - Executors.newFixedThreadPool(getDynamicConfigs().getBalancerComputeThreads())); + balancerExec = MoreExecutors.listeningDecorator(Execs.multiThreaded( + getDynamicConfigs().getBalancerComputeThreads(), + "coordinator-cost-balancer-%s" + )); BalancerStrategy balancerStrategy = factory.createBalancerStrategy(balancerExec); // Do coordinator stuff.