aboutsummaryrefslogtreecommitdiffstats
path: root/container-search
diff options
context:
space:
mode:
authorJon Bratseth <bratseth@verizonmedia.com>2019-11-18 13:16:54 +0100
committerJon Bratseth <bratseth@verizonmedia.com>2019-11-18 13:16:54 +0100
commit34e83218cc7b210137b633bc3e99f9b99dda3e19 (patch)
treee3c8862607596cf4b481e1c615db6f4586ddfa17 /container-search
parent2d07304049b00d679403b143adee7b481b099bb8 (diff)
Do rebalancing deployments in the Rebalancer
This avoids cases where the Rebalancer chooses a move which turns out to not be legal when actually making the redeployment, causing another node to be selected as target.
Diffstat (limited to 'container-search')
-rw-r--r--container-search/src/main/java/com/yahoo/search/dispatch/Dispatcher.java6
1 files changed, 2 insertions, 4 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 ab010001d90..e078ffa685f 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
@@ -90,9 +90,7 @@ public class Dispatcher extends AbstractComponent {
metric);
}
- private Dispatcher(SearchCluster searchCluster,
- DispatchConfig dispatchConfig,
- Metric metric) {
+ private Dispatcher(SearchCluster searchCluster, DispatchConfig dispatchConfig, Metric metric) {
this(searchCluster,
dispatchConfig,
new RpcInvokerFactory(new RpcResourcePool(dispatchConfig), searchCluster),
@@ -161,7 +159,7 @@ public class Dispatcher extends AbstractComponent {
List<Node> nodes = SearchPath.selectNodes(searchPath, searchCluster);
if (nodes.isEmpty()) return Optional.empty();
- query.trace(false, 2, "Dispatching internally with search path ", searchPath);
+ query.trace(false, 2, "Dispatching with search path ", searchPath);
return invokerFactory.createSearchInvoker(searcher, query, OptionalInt.empty(), nodes, true);
} catch (InvalidSearchPathException e) {
return Optional.of(new SearchErrorInvoker(ErrorMessage.createIllegalQuery(e.getMessage())));