diff options
author | Jon Bratseth <bratseth@gmail.com> | 2020-04-15 22:19:34 +0200 |
---|---|---|
committer | Jon Bratseth <bratseth@gmail.com> | 2020-04-15 22:19:34 +0200 |
commit | 0c68f849c445c82e75ad439965e1b057cff5181e (patch) | |
tree | 467383d181ad413ef96cd4a1f7f25bfbe405c1a5 /container-search/src/main/java/com/yahoo/search/dispatch/LoadBalancer.java | |
parent | 1eecdac6160ea9f7ed6de5e3fc478bc211561dc2 (diff) |
Avoid a single group rejecting feed
Diffstat (limited to 'container-search/src/main/java/com/yahoo/search/dispatch/LoadBalancer.java')
-rw-r--r-- | container-search/src/main/java/com/yahoo/search/dispatch/LoadBalancer.java | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/container-search/src/main/java/com/yahoo/search/dispatch/LoadBalancer.java b/container-search/src/main/java/com/yahoo/search/dispatch/LoadBalancer.java index 210ab5777d2..05e1ea6e2f9 100644 --- a/container-search/src/main/java/com/yahoo/search/dispatch/LoadBalancer.java +++ b/container-search/src/main/java/com/yahoo/search/dispatch/LoadBalancer.java @@ -134,6 +134,7 @@ public class LoadBalancer { } private static class RoundRobinScheduler implements GroupScheduler { + private int needle = 0; private final List<GroupStatus> scoreboard; @@ -204,6 +205,7 @@ public class LoadBalancer { } static class AdaptiveScheduler implements GroupScheduler { + private final Random random; private final List<GroupStatus> scoreboard; @@ -251,4 +253,5 @@ public class LoadBalancer { return selectGroup(needle, false, rejectedGroups); } } + } |