summaryrefslogtreecommitdiffstats
path: root/node-repository
diff options
context:
space:
mode:
authorandreer <andreer@verizonmedia.com>2020-05-22 11:25:56 +0200
committerandreer <andreer@verizonmedia.com>2020-05-22 11:25:56 +0200
commitd5dfc0d8189cc743a147b65bc116f0cd1d2140ba (patch)
treeb62c50aac8e4c97336b40896be9aa021bbbe7a22 /node-repository
parent0e8f55a17106adaf6d7d134fd9752c170deb1e4f (diff)
only throttle node failures when nodes are still in state "failed"
Diffstat (limited to 'node-repository')
-rw-r--r--node-repository/src/main/java/com/yahoo/vespa/hosted/provision/maintenance/NodeFailer.java1
1 files changed, 1 insertions, 0 deletions
diff --git a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/maintenance/NodeFailer.java b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/maintenance/NodeFailer.java
index 7ce674cbbbf..17f25689a76 100644
--- a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/maintenance/NodeFailer.java
+++ b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/maintenance/NodeFailer.java
@@ -386,6 +386,7 @@ public class NodeFailer extends NodeRepositoryMaintainer {
Instant startOfThrottleWindow = clock.instant().minus(throttlePolicy.throttleWindow);
List<Node> nodes = nodeRepository().getNodes();
NodeList recentlyFailedNodes = nodes.stream()
+ .filter(n -> n.state() == Node.State.failed)
.filter(n -> n.history().hasEventAfter(History.Event.Type.failed, startOfThrottleWindow))
.collect(collectingAndThen(Collectors.toList(), NodeList::copyOf));