Skip to content

Commit 4b9a3ad

Browse files
committed
Reinstate setWaitForActiveShards
1 parent 0cb237d commit 4b9a3ad

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

server/src/internalClusterTest/java/org/elasticsearch/cluster/routing/allocation/decider/DiskThresholdDeciderIT.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -18,6 +18,7 @@
1818
import org.elasticsearch.action.admin.indices.shrink.TransportResizeAction;
1919
import org.elasticsearch.action.admin.indices.stats.ShardStats;
2020
import org.elasticsearch.action.support.ActionTestUtils;
21+
import org.elasticsearch.action.support.ActiveShardCount;
2122
import org.elasticsearch.action.support.SubscribableListener;
2223
import org.elasticsearch.cluster.ClusterInfoService;
2324
import org.elasticsearch.cluster.ClusterInfoServiceUtils;
@@ -148,6 +149,7 @@ public void testAllocateCloneIgnoresLowWatermark() throws Exception {
148149
targetIndexName,
149150
indexSettings(1, 0)
150151
);
152+
resizeRequest.setWaitForActiveShards(ActiveShardCount.ALL);
151153

152154
safeAwait(
153155
SubscribableListener.<CreateIndexResponse>newForked(l -> client().execute(TransportResizeAction.TYPE, resizeRequest, l))

0 commit comments

Comments
 (0)