diff options
author | Jon Bratseth <bratseth@verizonmedia.com> | 2019-09-19 12:19:48 +0200 |
---|---|---|
committer | Jon Bratseth <bratseth@verizonmedia.com> | 2019-09-19 12:19:48 +0200 |
commit | 6d4addd1f27746ee530c56bfa513659a7576b08b (patch) | |
tree | 21b0b829a09f9d4d9fba63043a2a81b5652c9672 /container-search/src/main/java/com/yahoo/search/dispatch/searchcluster | |
parent | 9bf4d074cb4c14a7bbd70c441a80cd68fbf88e92 (diff) |
Be in service if we can reach any nodes regardless of whether they have data
Diffstat (limited to 'container-search/src/main/java/com/yahoo/search/dispatch/searchcluster')
-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) { |