From 8a7e7e773ab29f896e7df0dc6465c38d456ce708 Mon Sep 17 00:00:00 2001 From: Clint Wylie Date: Fri, 12 Jun 2020 13:09:22 -0700 Subject: [PATCH] fix balancer + broadcast segments npe (#10021) --- .../coordinator/DruidCoordinatorRuntimeParams.java | 10 +++++++--- 1 file changed, 7 insertions(+), 3 deletions(-) diff --git a/server/src/main/java/org/apache/druid/server/coordinator/DruidCoordinatorRuntimeParams.java b/server/src/main/java/org/apache/druid/server/coordinator/DruidCoordinatorRuntimeParams.java index 3337b8e7647..d73febeca0e 100644 --- a/server/src/main/java/org/apache/druid/server/coordinator/DruidCoordinatorRuntimeParams.java +++ b/server/src/main/java/org/apache/druid/server/coordinator/DruidCoordinatorRuntimeParams.java @@ -226,7 +226,8 @@ public class DruidCoordinatorRuntimeParams coordinatorCompactionConfig, stats, balancerReferenceTimestamp, - balancerStrategy + balancerStrategy, + broadcastDatasources ); } @@ -246,7 +247,8 @@ public class DruidCoordinatorRuntimeParams coordinatorCompactionConfig, stats, balancerReferenceTimestamp, - balancerStrategy + balancerStrategy, + broadcastDatasources ); } @@ -300,7 +302,8 @@ public class DruidCoordinatorRuntimeParams CoordinatorCompactionConfig coordinatorCompactionConfig, CoordinatorStats stats, DateTime balancerReferenceTimestamp, - BalancerStrategy balancerStrategy + BalancerStrategy balancerStrategy, + Set broadcastDatasources ) { this.startTimeNanos = startTimeNanos; @@ -317,6 +320,7 @@ public class DruidCoordinatorRuntimeParams this.stats = stats; this.balancerReferenceTimestamp = balancerReferenceTimestamp; this.balancerStrategy = balancerStrategy; + this.broadcastDatasources = broadcastDatasources; } public DruidCoordinatorRuntimeParams build()