Merge pull request #26662 from vespa-engine/jonmv/restart-container-when-content-cluster-is-removed

Restart all application container clusters when content clusters are …

1 files changed, 18 insertions, 7 deletions

diff --git a/config-model/src/main/java/com/yahoo/vespa/model/application/validation/change/ContentClusterRemovalValidator.java b/config-model/src/main/java/com/yahoo/vespa/model/application/validation/change/ContentClusterRemovalValidator.java
index 0cc52edf3cc..b1eace947cc 100644
--- a/config-model/src/main/java/com/yahoo/vespa/model/application/validation/change/ContentClusterRemovalValidator.java
+++ b/config-model/src/main/java/com/yahoo/vespa/model/application/validation/change/ContentClusterRemovalValidator.java
@@ -2,11 +2,15 @@
 package com.yahoo.vespa.model.application.validation.change;
 
 import com.yahoo.config.model.api.ConfigChangeAction;
+import com.yahoo.config.model.api.ServiceInfo;
 import com.yahoo.config.model.deploy.DeployState;
 import com.yahoo.vespa.model.VespaModel;
 import com.yahoo.config.application.api.ValidationId;
+import com.yahoo.vespa.model.container.ApplicationContainer;
+import com.yahoo.vespa.model.container.ApplicationContainerCluster;
 import com.yahoo.vespa.model.content.cluster.ContentCluster;
 
+import java.util.ArrayList;
 import java.util.List;
 
 /**
@@ -19,16 +23,23 @@ public class ContentClusterRemovalValidator implements ChangeValidator {
 
     @Override
     public List<ConfigChangeAction> validate(VespaModel current, VespaModel next, DeployState deployState) {
+        List<ConfigChangeAction> actions = new ArrayList<>();
         for (String currentClusterId : current.getContentClusters().keySet()) {
             ContentCluster nextCluster = next.getContentClusters().get(currentClusterId);
-            if (nextCluster == null)
+            if (nextCluster == null) {
                 deployState.validationOverrides().invalid(ValidationId.contentClusterRemoval,
-                                  "Content cluster '" + currentClusterId + "' is removed. " +
-                                  "This will cause loss of all data in this cluster",
-                                  deployState.now());
-        }
+                                                          "Content cluster '" + currentClusterId + "' is removed. " +
+                                                          "This will cause loss of all data in this cluster",
+                                                          deployState.now());
 
-        return List.of();
+                // If we allow the removal, we must restart all containers to ensure mbus is OK.
+                for (ApplicationContainerCluster cluster : next.getContainerClusters().values()) {
+                    actions.add(new VespaRestartAction(cluster.id(),
+                                                       "Content cluster '" + currentClusterId + "' has been removed",
+                                                       cluster.getContainers().stream().map(ApplicationContainer::getServiceInfo).toList()));
+                }
+            }
+        }
+        return actions;
     }
-
 }