From 5bbe13f10bf2b50b2215080101bcb92f2677b006 Mon Sep 17 00:00:00 2001 From: Clint Wylie Date: Thu, 11 Jun 2020 06:36:56 -0700 Subject: [PATCH] fix balancer + broadcast segments npe --- .../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 3337b8e7647a..d73febeca0e3 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 Builder buildFromExisting() coordinatorCompactionConfig, stats, balancerReferenceTimestamp, - balancerStrategy + balancerStrategy, + broadcastDatasources ); } @@ -246,7 +247,8 @@ public Builder buildFromExistingWithoutSegmentsMetadata() coordinatorCompactionConfig, stats, balancerReferenceTimestamp, - balancerStrategy + balancerStrategy, + broadcastDatasources ); } @@ -300,7 +302,8 @@ private Builder() CoordinatorCompactionConfig coordinatorCompactionConfig, CoordinatorStats stats, DateTime balancerReferenceTimestamp, - BalancerStrategy balancerStrategy + BalancerStrategy balancerStrategy, + Set broadcastDatasources ) { this.startTimeNanos = startTimeNanos; @@ -317,6 +320,7 @@ private Builder() this.stats = stats; this.balancerReferenceTimestamp = balancerReferenceTimestamp; this.balancerStrategy = balancerStrategy; + this.broadcastDatasources = broadcastDatasources; } public DruidCoordinatorRuntimeParams build()