diff options
author | Martin Polden <mpolden@mpolden.no> | 2020-03-04 13:27:21 +0100 |
---|---|---|
committer | GitHub <noreply@github.com> | 2020-03-04 13:27:21 +0100 |
commit | e8de2c9f3a5c3f16068673ec742274be512af82e (patch) | |
tree | 9f0a224f99b35c5ed2d8c86f5c331537a84db73a /node-repository | |
parent | ef444e66c24ab1c8b926c09586a6a5a138f64406 (diff) | |
parent | 8e9bd2542fa425df75685f97c00f2d52345d0f80 (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.java | 11 |
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(); } } |