diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2021-04-16 23:39:30 +0200 |
---|---|---|
committer | GitHub <noreply@github.com> | 2021-04-16 23:39:30 +0200 |
commit | b07dffa84009b99147e52a2902c83bc9a1294cd6 (patch) | |
tree | d25d6bde582afa1dc0cdc667953d4e73f31c2082 | |
parent | 228bbd8020b1922d53ef21f7ce5ae59d142f39c4 (diff) | |
parent | c80fd0f7f2605a50f800e78a56c2a298d5050fb6 (diff) |
Merge pull request #17465 from vespa-engine/bratseth/improve-message
Improve coverage message
-rw-r--r-- | container-search/src/main/java/com/yahoo/search/dispatch/searchcluster/SearchCluster.java | 21 |
1 files changed, 10 insertions, 11 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 421082bb5dc..ce834b108db 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 @@ -358,7 +358,6 @@ public class SearchCluster implements NodeManager<Node> { private boolean isGroupCoverageSufficient(int workingNodesInGroup, long activeDocuments, long medianDocuments) { double documentCoverage = 100.0 * (double) activeDocuments / medianDocuments; - if (medianDocuments > 0 && documentCoverage < dispatchConfig.minActivedocsPercentage()) return false; @@ -397,19 +396,19 @@ public class SearchCluster implements NodeManager<Node> { nextLogTime = System.currentTimeMillis() + 30 * 1000; int requiredNodes = group.nodes().size() - dispatchConfig.maxNodesDownPerGroup(); if (fullCoverage) { - log.info(() -> String.format("Cluster %s: %s is now good again (%d/%d active docs, coverage %d/%d)", - clusterId, group, group.getActiveDocuments(), medianDocuments, - group.workingNodes(), group.nodes().size())); + log.info("Cluster " + clusterId + ": " + group + " has full coverage. " + + "Active documents: " + group.getActiveDocuments() + "/" + medianDocuments + ", " + + "working nodes: " + group.workingNodes() + "/" + group.nodes().size()); } else { - StringBuilder missing = new StringBuilder(); + StringBuilder unresponsive = new StringBuilder(); for (var node : group.nodes()) { - if (node.isWorking() != Boolean.TRUE) { - missing.append('\n').append(node); - } + if (node.isWorking() != Boolean.TRUE) + unresponsive.append('\n').append(node); } - log.warning(() -> String.format("Cluster %s: Coverage of %s is only %d/%d (requires %d) (%d/%d active docs) Failed nodes are:%s", - clusterId, group, group.workingNodes(), group.nodes().size(), requiredNodes, - group.getActiveDocuments(), medianDocuments, missing)); + log.warning("Cluster " + clusterId + ": " + group + " has reduced coverage: " + + "Active documents: " + group.getActiveDocuments() + "/" + medianDocuments + ", " + + "working nodes: " + group.workingNodes() + "/" + group.nodes().size() + " required " + requiredNodes + + ", unresponsive nodes: " + (unresponsive.toString().isEmpty() ? " none" : unresponsive)); } } } |