diff options
author | Martin Polden <mpolden@mpolden.no> | 2023-11-28 14:02:22 +0100 |
---|---|---|
committer | Martin Polden <mpolden@mpolden.no> | 2023-11-28 14:20:36 +0100 |
commit | 4bb1c9671f04d3c746dfe95aecc621db626a0a96 (patch) | |
tree | e4d84ee3a3903d7fc07e1e9d641f115db06a4b94 /node-repository/src/main/java | |
parent | 7fc4d391aee5bf8cade54507453d193370ad841d (diff) |
Avoid moves to hosts that contain cluster nodes in any state
Diffstat (limited to 'node-repository/src/main/java')
-rw-r--r-- | node-repository/src/main/java/com/yahoo/vespa/hosted/provision/maintenance/SwitchRebalancer.java | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/maintenance/SwitchRebalancer.java b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/maintenance/SwitchRebalancer.java index 5e600b990ae..9095250827d 100644 --- a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/maintenance/SwitchRebalancer.java +++ b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/maintenance/SwitchRebalancer.java @@ -69,9 +69,9 @@ public class SwitchRebalancer extends NodeMover<Move> { private NodeList clusterOf(Node node, NodeList allNodes) { ApplicationId application = node.allocation().get().owner(); ClusterSpec.Id cluster = node.allocation().get().membership().cluster().id(); - return allNodes.state(Node.State.active) - .owner(application) - .cluster(cluster); + // This considers all states to prevent unnecessary moves. E.g. we don't want to start moving nodes to a host + // which already contain a failed node in our cluster + return allNodes.owner(application).cluster(cluster); } /** Returns whether allocatedNode is on an exclusive switch */ |