diff options
Diffstat (limited to 'container-search')
| -rw-r--r-- | container-search/src/main/java/com/yahoo/search/dispatch/searchcluster/SearchCluster.java | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/container-search/src/main/java/com/yahoo/search/dispatch/searchcluster/SearchCluster.java b/container-search/src/main/java/com/yahoo/search/dispatch/searchcluster/SearchCluster.java index 37ccd340f8a..2bcac6e2ce4 100644 --- a/container-search/src/main/java/com/yahoo/search/dispatch/searchcluster/SearchCluster.java +++ b/container-search/src/main/java/com/yahoo/search/dispatch/searchcluster/SearchCluster.java @@ -242,7 +242,7 @@ public class SearchCluster implements NodeManager<Node> { else { if ( ! hasInformationAboutAllNodes()) return; - if (hasWorkingNodesWithDocumentsOnline()) + if (hasWorkingNodes()) vipStatus.addToRotation(clusterId); else vipStatus.removeFromRotation(clusterId); @@ -267,8 +267,8 @@ public class SearchCluster implements NodeManager<Node> { return nodesByHost.values().stream().allMatch(Node::getStatusIsKnown); } - private boolean hasWorkingNodesWithDocumentsOnline() { - return nodesByHost.values().stream().anyMatch(node -> node.isWorking() && node.getActiveDocuments() > 0); + private boolean hasWorkingNodes() { + return nodesByHost.values().stream().anyMatch(Node::isWorking); } private boolean usesLocalCorpusIn(Node node) { |