diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2020-02-11 07:22:03 +0000 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2020-02-11 07:22:03 +0000 |
commit | 413452ee7acb2d404d2cabd9e73d1c1846b68ee5 (patch) | |
tree | f1e88a3e5b650f243414d6101d988b72e386358e | |
parent | 648d3428ab476b7ad26c04047de610a497966c92 (diff) |
Compute full group and coverage state before we say we are complete.
-rw-r--r-- | container-search/src/main/java/com/yahoo/search/dispatch/Dispatcher.java | 8 |
1 files changed, 8 insertions, 0 deletions
diff --git a/container-search/src/main/java/com/yahoo/search/dispatch/Dispatcher.java b/container-search/src/main/java/com/yahoo/search/dispatch/Dispatcher.java index 91bd5c6da11..24ecea9c3ee 100644 --- a/container-search/src/main/java/com/yahoo/search/dispatch/Dispatcher.java +++ b/container-search/src/main/java/com/yahoo/search/dispatch/Dispatcher.java @@ -132,6 +132,14 @@ public class Dispatcher extends AbstractComponent { Thread.sleep(1); } } catch (InterruptedException e) {} + + /* + * No we have information from all nodes and a ping iteration has completed. + * Instead of waiting until next ping interval to update coverage and group state, + * we should compute the state ourselves, so that when the dispatcher is ready the state + * of its groups are also known. + */ + searchCluster.pingIterationCompleted(); } /** Returns the search cluster this dispatches to */ |