diff options
author | Torbjørn Smørgrav <smorgrav@users.noreply.github.com> | 2020-05-25 11:29:59 +0200 |
---|---|---|
committer | GitHub <noreply@github.com> | 2020-05-25 11:29:59 +0200 |
commit | 33783c76db94810034cca076bf1ca88a9f164862 (patch) | |
tree | facf060cae3a910f8084f2ec66f035a6e806b328 | |
parent | 9fbf28d399520f05180904cde08ece6a27736046 (diff) | |
parent | d5dfc0d8189cc743a147b65bc116f0cd1d2140ba (diff) |
Merge pull request #13343 from vespa-engine/andreer/only-throttle-when-nodes-are-still-in-failed
only throttle node failures when nodes are still in state "failed"
-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)); |