From b65c9bd134940f56fcbb966caacba34035c16660 Mon Sep 17 00:00:00 2001 From: Charles Allen Date: Thu, 1 Jun 2017 22:54:13 -0700 Subject: [PATCH] Make the Coordinator Cost Balancer thread naming human friendly --- .../java/io/druid/server/coordinator/DruidCoordinator.java | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) 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.