diff options
-rw-r--r-- | core/src/main/java/org/elasticsearch/indices/cluster/IndicesClusterStateService.java | 3 |
1 files changed, 0 insertions, 3 deletions
diff --git a/core/src/main/java/org/elasticsearch/indices/cluster/IndicesClusterStateService.java b/core/src/main/java/org/elasticsearch/indices/cluster/IndicesClusterStateService.java index 97f57e216c..0f8ae2185e 100644 --- a/core/src/main/java/org/elasticsearch/indices/cluster/IndicesClusterStateService.java +++ b/core/src/main/java/org/elasticsearch/indices/cluster/IndicesClusterStateService.java @@ -382,14 +382,11 @@ public class IndicesClusterStateService extends AbstractLifecycleComponent imple /** * Removes shards that are currently loaded by indicesService but have disappeared from the routing table of the current node. - * Also removes shards where the recovery source node has changed. * This method does not delete the shard data. * * @param state new cluster state */ private void removeShards(final ClusterState state) { - final RoutingTable routingTable = state.routingTable(); - final DiscoveryNodes nodes = state.nodes(); final String localNodeId = state.nodes().getLocalNodeId(); assert localNodeId != null; |