summaryrefslogtreecommitdiffstats
path: root/container-search/src/main
diff options
context:
space:
mode:
authorJon Bratseth <bratseth@gmail.com>2020-04-16 13:19:45 +0200
committerJon Bratseth <bratseth@gmail.com>2020-04-16 13:19:45 +0200
commitb6789d50ecc94a268b05a814479e9decd5c5aca8 (patch)
tree32ce9ff68d9372e8e6730a1a80250983ec0c66ab /container-search/src/main
parent1b2ed96d011cd1c8cec11584baa584b6a60dd484 (diff)
isWorking is tri-state
Diffstat (limited to 'container-search/src/main')
-rw-r--r--container-search/src/main/java/com/yahoo/search/dispatch/searchcluster/Group.java2
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()));
}