You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@druid.apache.org by cw...@apache.org on 2020/06/12 20:09:43 UTC
[druid] branch master updated: fix balancer + broadcast segments
npe (#10021)
This is an automated email from the ASF dual-hosted git repository.
cwylie pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/druid.git
The following commit(s) were added to refs/heads/master by this push:
new 8a7e7e7 fix balancer + broadcast segments npe (#10021)
8a7e7e7 is described below
commit 8a7e7e773ab29f896e7df0dc6465c38d456ce708
Author: Clint Wylie <cw...@apache.org>
AuthorDate: Fri Jun 12 13:09:22 2020 -0700
fix balancer + broadcast segments npe (#10021)
---
.../server/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 3337b8e..d73febe 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<String> 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()
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@druid.apache.org
For additional commands, e-mail: commits-help@druid.apache.org