diff options
author | Jon Bratseth <bratseth@vespa.ai> | 2023-07-12 08:58:02 +0200 |
---|---|---|
committer | Jon Bratseth <bratseth@vespa.ai> | 2023-07-12 08:58:02 +0200 |
commit | 54c45551d4deeb423e254e0f721806fd6b7f89c5 (patch) | |
tree | fd19efad37d237638357889438538b09e709ae96 /node-repository | |
parent | 6163206dab8a5b0f921eca424f1504e49661372c (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.java | 17 |
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))); - } - } - } - } |