summaryrefslogtreecommitdiffstats
path: root/node-repository
diff options
context:
space:
mode:
authorMartin Polden <mpolden@mpolden.no>2020-03-04 13:27:21 +0100
committerGitHub <noreply@github.com>2020-03-04 13:27:21 +0100
commite8de2c9f3a5c3f16068673ec742274be512af82e (patch)
tree9f0a224f99b35c5ed2d8c86f5c331537a84db73a /node-repository
parentef444e66c24ab1c8b926c09586a6a5a138f64406 (diff)
parent8e9bd2542fa425df75685f97c00f2d52345d0f80 (diff)
Merge pull request #12432 from vespa-engine/mpolden/expire-lbs-combined
Remove inactive load balancers for combined cluster
Diffstat (limited to 'node-repository')
-rw-r--r--node-repository/src/main/java/com/yahoo/vespa/hosted/provision/maintenance/LoadBalancerExpirer.java11
1 files changed, 10 insertions, 1 deletions
diff --git a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/maintenance/LoadBalancerExpirer.java b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/maintenance/LoadBalancerExpirer.java
index e2b70608d58..93f0b75dcdf 100644
--- a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/maintenance/LoadBalancerExpirer.java
+++ b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/maintenance/LoadBalancerExpirer.java
@@ -1,6 +1,7 @@
// Copyright 2018 Yahoo Holdings. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
package com.yahoo.vespa.hosted.provision.maintenance;
+import com.yahoo.config.provision.ClusterSpec;
import com.yahoo.log.LogLevel;
import com.yahoo.vespa.hosted.provision.Node;
import com.yahoo.vespa.hosted.provision.NodeRepository;
@@ -130,7 +131,15 @@ public class LoadBalancerExpirer extends Maintainer {
}
private List<Node> allocatedNodes(LoadBalancerId loadBalancer) {
- return nodeRepository().list().owner(loadBalancer.application()).cluster(loadBalancer.cluster()).asList();
+ return nodeRepository().list()
+ .owner(loadBalancer.application())
+ .cluster(loadBalancer.cluster())
+ // TODO(mpolden): Remove after March 2020. This ignores nodes in combined clusters so
+ // that inactive load balancers for combined clusters with wrong ID are
+ // eventually removed.
+ .filter(node -> node.allocation().isPresent() &&
+ node.allocation().get().membership().cluster().type() != ClusterSpec.Type.combined)
+ .asList();
}
}