When refreshing, also execute the refresh operation on initializing shards to make sure we don't miss it, closes #1370.

This commit is contained in:
Shay Banon 2011-09-27 21:46:24 +03:00
parent de8644d95a
commit df3fa9c067
1 changed files with 1 additions and 1 deletions

View File

@ -120,6 +120,6 @@ public class TransportRefreshAction extends TransportBroadcastOperationAction<Re
* The refresh request works against *all* shards. * The refresh request works against *all* shards.
*/ */
@Override protected GroupShardsIterator shards(RefreshRequest request, String[] concreteIndices, ClusterState clusterState) { @Override protected GroupShardsIterator shards(RefreshRequest request, String[] concreteIndices, ClusterState clusterState) {
return clusterState.routingTable().allActiveShardsGrouped(concreteIndices, true); return clusterState.routingTable().allAssignedShardsGrouped(concreteIndices, true);
} }
} }