diff --git a/src/main/java/org/elasticsearch/discovery/local/LocalDiscovery.java b/src/main/java/org/elasticsearch/discovery/local/LocalDiscovery.java index 5511ad213cf..9561db44ae9 100644 --- a/src/main/java/org/elasticsearch/discovery/local/LocalDiscovery.java +++ b/src/main/java/org/elasticsearch/discovery/local/LocalDiscovery.java @@ -220,7 +220,7 @@ public class LocalDiscovery extends AbstractLifecycleComponent implem } // reroute here, so we eagerly remove dead nodes from the routing ClusterState updatedState = newClusterStateBuilder().state(currentState).nodes(newNodes).build(); - RoutingAllocation.Result routingResult = allocationService.reroute(newClusterStateBuilder().state(updatedState).build()); + RoutingAllocation.Result routingResult = master.allocationService.reroute(newClusterStateBuilder().state(updatedState).build()); return newClusterStateBuilder().state(updatedState).routingResult(routingResult).build(); } });