diff options
author | andreer <andreer@verizonmedia.com> | 2020-05-22 11:25:56 +0200 |
---|---|---|
committer | andreer <andreer@verizonmedia.com> | 2020-05-22 11:25:56 +0200 |
commit | d5dfc0d8189cc743a147b65bc116f0cd1d2140ba (patch) | |
tree | b62c50aac8e4c97336b40896be9aa021bbbe7a22 /node-repository | |
parent | 0e8f55a17106adaf6d7d134fd9752c170deb1e4f (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.java | 1 |
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)); |