diff options
Diffstat (limited to 'core/src/main/java/org/elasticsearch/cluster/routing/DelayedAllocationService.java')
-rw-r--r-- | core/src/main/java/org/elasticsearch/cluster/routing/DelayedAllocationService.java | 7 |
1 files changed, 1 insertions, 6 deletions
diff --git a/core/src/main/java/org/elasticsearch/cluster/routing/DelayedAllocationService.java b/core/src/main/java/org/elasticsearch/cluster/routing/DelayedAllocationService.java index 29d74dd893..55c6750b82 100644 --- a/core/src/main/java/org/elasticsearch/cluster/routing/DelayedAllocationService.java +++ b/core/src/main/java/org/elasticsearch/cluster/routing/DelayedAllocationService.java @@ -106,12 +106,7 @@ public class DelayedAllocationService extends AbstractLifecycleComponent impleme @Override public ClusterState execute(ClusterState currentState) throws Exception { removeIfSameTask(this); - RoutingAllocation.Result routingResult = allocationService.reroute(currentState, "assign delayed unassigned shards"); - if (routingResult.changed()) { - return ClusterState.builder(currentState).routingResult(routingResult).build(); - } else { - return currentState; - } + return allocationService.reroute(currentState, "assign delayed unassigned shards"); } @Override |