diff options
Diffstat (limited to 'core/src/main/java/org/elasticsearch/gateway/GatewayService.java')
-rw-r--r-- | core/src/main/java/org/elasticsearch/gateway/GatewayService.java | 8 |
1 files changed, 2 insertions, 6 deletions
diff --git a/core/src/main/java/org/elasticsearch/gateway/GatewayService.java b/core/src/main/java/org/elasticsearch/gateway/GatewayService.java index b953173c68..856574748d 100644 --- a/core/src/main/java/org/elasticsearch/gateway/GatewayService.java +++ b/core/src/main/java/org/elasticsearch/gateway/GatewayService.java @@ -34,7 +34,6 @@ import org.elasticsearch.cluster.metadata.MetaData; import org.elasticsearch.cluster.node.DiscoveryNodes; import org.elasticsearch.cluster.routing.RoutingTable; import org.elasticsearch.cluster.routing.allocation.AllocationService; -import org.elasticsearch.cluster.routing.allocation.RoutingAllocation; import org.elasticsearch.cluster.service.ClusterService; import org.elasticsearch.common.component.AbstractLifecycleComponent; import org.elasticsearch.common.inject.Inject; @@ -282,11 +281,8 @@ public class GatewayService extends AbstractLifecycleComponent implements Cluste routingTableBuilder.version(0); // now, reroute - RoutingAllocation.Result routingResult = allocationService.reroute( - ClusterState.builder(updatedState).routingTable(routingTableBuilder.build()).build(), - "state recovered"); - - return ClusterState.builder(updatedState).routingResult(routingResult).build(); + updatedState = ClusterState.builder(updatedState).routingTable(routingTableBuilder.build()).build(); + return allocationService.reroute(updatedState, "state recovered"); } @Override |