diff --git a/server/src/main/java/io/druid/server/coordinator/CoordinatorDynamicConfig.java b/server/src/main/java/io/druid/server/coordinator/CoordinatorDynamicConfig.java index 62f07d8474d5..f4eaa7a5e2b2 100644 --- a/server/src/main/java/io/druid/server/coordinator/CoordinatorDynamicConfig.java +++ b/server/src/main/java/io/druid/server/coordinator/CoordinatorDynamicConfig.java @@ -57,10 +57,7 @@ public CoordinatorDynamicConfig( this.replicantLifetime = replicantLifetime; this.replicationThrottleLimit = replicationThrottleLimit; this.emitBalancingStats = emitBalancingStats; - this.balancerComputeThreads = Math.min( - Math.max(balancerComputeThreads, 1), - Math.max(Runtime.getRuntime().availableProcessors() - 1, 1) - ); + this.balancerComputeThreads = Math.max(balancerComputeThreads, 1); this.killDataSourceWhitelist = killDataSourceWhitelist; } diff --git a/server/src/test/java/io/druid/server/http/CoordinatorDynamicConfigTest.java b/server/src/test/java/io/druid/server/http/CoordinatorDynamicConfigTest.java index af5bb477eccf..c4536627e694 100644 --- a/server/src/test/java/io/druid/server/http/CoordinatorDynamicConfigTest.java +++ b/server/src/test/java/io/druid/server/http/CoordinatorDynamicConfigTest.java @@ -40,6 +40,7 @@ public void testSerde() throws Exception + " \"maxSegmentsToMove\": 1,\n" + " \"replicantLifetime\": 1,\n" + " \"replicationThrottleLimit\": 1,\n" + + " \"balancerComputeThreads\": 2, \n" + " \"emitBalancingStats\": true,\n" + " \"killDataSourceWhitelist\": [\"test\"]\n" + "}\n"; @@ -56,7 +57,7 @@ public void testSerde() throws Exception ); Assert.assertEquals( - new CoordinatorDynamicConfig(1, 1, 1, 1, 1, 1, 1, true, ImmutableSet.of("test")), + new CoordinatorDynamicConfig(1, 1, 1, 1, 1, 1, 2, true, ImmutableSet.of("test")), actual ); }