aboutsummaryrefslogtreecommitdiffstats
path: root/config-model/src/main/java/com/yahoo/vespa/model/admin/clustercontroller/ClusterControllerContainerCluster.java
diff options
context:
space:
mode:
authorBjørn Christian Seime <bjorncs@verizonmedia.com>2020-12-07 14:45:41 +0100
committerBjørn Christian Seime <bjorncs@verizonmedia.com>2020-12-07 14:45:41 +0100
commit91ef9fa19596c2774daafa5e8d0c8a112f3c12db (patch)
treeccdd05eddf2088ed494fc2009a7cfbef29c5079c /config-model/src/main/java/com/yahoo/vespa/model/admin/clustercontroller/ClusterControllerContainerCluster.java
parenta17f50d51e211fff019e21a5d3151f2d4551f18e (diff)
Add back feature flag wiring that was removed accidentally
Diffstat (limited to 'config-model/src/main/java/com/yahoo/vespa/model/admin/clustercontroller/ClusterControllerContainerCluster.java')
-rw-r--r--config-model/src/main/java/com/yahoo/vespa/model/admin/clustercontroller/ClusterControllerContainerCluster.java10
1 files changed, 9 insertions, 1 deletions
diff --git a/config-model/src/main/java/com/yahoo/vespa/model/admin/clustercontroller/ClusterControllerContainerCluster.java b/config-model/src/main/java/com/yahoo/vespa/model/admin/clustercontroller/ClusterControllerContainerCluster.java
index c202d29cc5d..63fc0b4515f 100644
--- a/config-model/src/main/java/com/yahoo/vespa/model/admin/clustercontroller/ClusterControllerContainerCluster.java
+++ b/config-model/src/main/java/com/yahoo/vespa/model/admin/clustercontroller/ClusterControllerContainerCluster.java
@@ -10,6 +10,7 @@ import com.yahoo.vespa.model.container.ContainerCluster;
* Container cluster for cluster-controller containers.
*
* @author gjoranv
+ * @author bjorncs
*/
public class ClusterControllerContainerCluster extends ContainerCluster<ClusterControllerContainer>
{
@@ -20,7 +21,7 @@ public class ClusterControllerContainerCluster extends ContainerCluster<ClusterC
AbstractConfigProducer<?> parent, String subId, String name, DeployState deployState) {
super(parent, subId, name, deployState, false);
addDefaultHandlersWithVip();
- this.reindexingContext = new ReindexingContext(deployState.reindexing().orElse(Reindexing.DISABLED_INSTANCE));
+ this.reindexingContext = createReindexingContext(deployState);
}
@Override
@@ -30,4 +31,11 @@ public class ClusterControllerContainerCluster extends ContainerCluster<ClusterC
public ReindexingContext reindexingContext() { return reindexingContext; }
+ private static ReindexingContext createReindexingContext(DeployState deployState) {
+ Reindexing reindexing = deployState.featureFlags().enableAutomaticReindexing()
+ ? deployState.reindexing().orElse(Reindexing.DISABLED_INSTANCE)
+ : Reindexing.DISABLED_INSTANCE;
+ return new ReindexingContext(reindexing);
+ }
+
}