diff options
author | Jon Bratseth <bratseth@gmail.com> | 2020-04-16 13:19:45 +0200 |
---|---|---|
committer | Jon Bratseth <bratseth@gmail.com> | 2020-04-16 13:19:45 +0200 |
commit | b6789d50ecc94a268b05a814479e9decd5c5aca8 (patch) | |
tree | 32ce9ff68d9372e8e6730a1a80250983ec0c66ab /container-search/src/main/java/com/yahoo | |
parent | 1b2ed96d011cd1c8cec11584baa584b6a60dd484 (diff) |
isWorking is tri-state
Diffstat (limited to 'container-search/src/main/java/com/yahoo')
-rw-r--r-- | container-search/src/main/java/com/yahoo/search/dispatch/searchcluster/Group.java | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/container-search/src/main/java/com/yahoo/search/dispatch/searchcluster/Group.java b/container-search/src/main/java/com/yahoo/search/dispatch/searchcluster/Group.java index ad2581696a7..ec616a18e09 100644 --- a/container-search/src/main/java/com/yahoo/search/dispatch/searchcluster/Group.java +++ b/container-search/src/main/java/com/yahoo/search/dispatch/searchcluster/Group.java @@ -63,7 +63,7 @@ public class Group { } void aggregateNodeValues() { - activeDocuments.set(nodes.stream().filter(Node::isWorking).mapToLong(Node::getActiveDocuments).sum()); + activeDocuments.set(nodes.stream().filter(node -> node.isWorking() == Boolean.TRUE).mapToLong(Node::getActiveDocuments).sum()); isBlockingWrites.set(nodes.stream().anyMatch(node -> node.isBlockingWrites())); } |