aboutsummaryrefslogtreecommitdiffstats
path: root/node-repository
diff options
context:
space:
mode:
authorJon Bratseth <bratseth@vespa.ai>2023-07-12 08:58:02 +0200
committerJon Bratseth <bratseth@vespa.ai>2023-07-12 08:58:02 +0200
commit54c45551d4deeb423e254e0f721806fd6b7f89c5 (patch)
treefd19efad37d237638357889438538b09e709ae96 /node-repository
parent6163206dab8a5b0f921eca424f1504e49661372c (diff)
Remove duplicate of processing done by GroupIndices
Diffstat (limited to 'node-repository')
-rw-r--r--node-repository/src/main/java/com/yahoo/vespa/hosted/provision/provisioning/Preparer.java17
1 files changed, 0 insertions, 17 deletions
diff --git a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/provisioning/Preparer.java b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/provisioning/Preparer.java
index a9e2333ea9f..5b2578d7a12 100644
--- a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/provisioning/Preparer.java
+++ b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/provisioning/Preparer.java
@@ -2,7 +2,6 @@
package com.yahoo.vespa.hosted.provision.provisioning;
import com.yahoo.config.provision.ApplicationId;
-import com.yahoo.config.provision.ClusterMembership;
import com.yahoo.config.provision.ClusterSpec;
import com.yahoo.config.provision.NodeAllocationException;
import com.yahoo.vespa.hosted.provision.LockedNodeList;
@@ -12,7 +11,6 @@ import com.yahoo.vespa.hosted.provision.NodeRepository;
import java.util.ArrayList;
import java.util.List;
-import java.util.ListIterator;
import java.util.Optional;
import java.util.stream.Collectors;
@@ -64,7 +62,6 @@ class Preparer {
.filter(node -> node.parentHostname().isEmpty() || activeHosts.parentOf(node).isPresent())
.toList();
}
- moveToActiveGroup(surplusNodes, requested.groups(), cluster.group());
return accepted.stream().filter(node -> ! surplusNodes.contains(node)).collect(Collectors.toList());
}
@@ -87,18 +84,4 @@ class Preparer {
return surplusNodes;
}
- /** Move nodes from unwanted groups to wanted groups to avoid lingering groups consisting of retired nodes */
- private void moveToActiveGroup(List<Node> surplusNodes, int wantedGroups, Optional<ClusterSpec.Group> targetGroup) {
- for (ListIterator<Node> i = surplusNodes.listIterator(); i.hasNext(); ) {
- Node node = i.next();
- ClusterMembership membership = node.allocation().get().membership();
- ClusterSpec cluster = membership.cluster();
- if (cluster.group().get().index() >= wantedGroups) {
- ClusterSpec.Group newGroup = targetGroup.orElse(ClusterSpec.Group.from(0));
- ClusterMembership newGroupMembership = membership.with(cluster.with(Optional.of(newGroup)));
- i.set(node.with(node.allocation().get().with(newGroupMembership)));
- }
- }
- }
-
}