Skip to content

Commit 7d26c64

Browse files
author
Andrey Ershov
committed
Fix testNotWaitForQuorumCopies
1 parent b508464 commit 7d26c64

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

server/src/test/java/org/elasticsearch/cluster/routing/PrimaryAllocationIT.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -341,17 +341,17 @@ public boolean clearData(String nodeName) {
341341

342342
public void testNotWaitForQuorumCopies() throws Exception {
343343
logger.info("--> starting 3 nodes");
344-
internalCluster().startNodes(3, Settings.builder().put(TestZenDiscovery.USE_ZEN2.getKey(), false).build()); // needs state recovery
344+
List<String> nodes = internalCluster().startNodes(3);
345345
logger.info("--> creating index with 1 primary and 2 replicas");
346346
assertAcked(client().admin().indices().prepareCreate("test").setSettings(Settings.builder()
347347
.put("index.number_of_shards", randomIntBetween(1, 3)).put("index.number_of_replicas", 2)).get());
348348
ensureGreen("test");
349349
client().prepareIndex("test", "type1").setSource(jsonBuilder()
350350
.startObject().field("field", "value1").endObject()).get();
351351
logger.info("--> removing 2 nodes from cluster");
352-
internalCluster().stopRandomDataNode();
353-
internalCluster().stopRandomDataNode();
354-
internalCluster().fullRestart();
352+
internalCluster().stopRandomNode(InternalTestCluster.nameFilter(nodes.get(1)));
353+
internalCluster().stopRandomNode(InternalTestCluster.nameFilter(nodes.get(2)));
354+
internalCluster().restartRandomDataNode();
355355
logger.info("--> checking that index still gets allocated with only 1 shard copy being available");
356356
ensureYellow("test");
357357
assertHitCount(client().prepareSearch().setSize(0).setQuery(matchAllQuery()).get(), 1L);

0 commit comments

Comments
 (0)