From 7f61b1540c31c09bc02668206c45eea6af93705b Mon Sep 17 00:00:00 2001 From: Boaz Leskes Date: Sun, 1 Mar 2015 09:02:23 +0100 Subject: [PATCH] Test: testOldIndexes start nodes async --- .../OldIndexBackwardsCompatibilityTests.java | 15 ++++----------- 1 file changed, 4 insertions(+), 11 deletions(-) diff --git a/src/test/java/org/elasticsearch/bwcompat/OldIndexBackwardsCompatibilityTests.java b/src/test/java/org/elasticsearch/bwcompat/OldIndexBackwardsCompatibilityTests.java index cbc9b7bfb49f6..73b361f0e4da4 100644 --- a/src/test/java/org/elasticsearch/bwcompat/OldIndexBackwardsCompatibilityTests.java +++ b/src/test/java/org/elasticsearch/bwcompat/OldIndexBackwardsCompatibilityTests.java @@ -45,12 +45,7 @@ import java.nio.file.Files; import java.nio.file.Path; import java.nio.file.Paths; -import java.util.ArrayList; -import java.util.Collections; -import java.util.List; -import java.util.Map; -import java.util.SortedSet; -import java.util.TreeSet; +import java.util.*; import static org.elasticsearch.test.hamcrest.ElasticsearchAssertions.assertAcked; @@ -168,14 +163,12 @@ void assertRealtimeGetWorks() { void assertNewReplicasWork() throws Exception { final int numReplicas = randomIntBetween(2, 3); - for (int i = 0; i < numReplicas; ++i) { - logger.debug("Creating another node for replica " + i); - internalCluster().startNode(ImmutableSettings.builder() + logger.debug("Creating [{}] nodes for replicas", numReplicas); + internalCluster().startNodesAsync(numReplicas, ImmutableSettings.builder() .put("data.node", true) .put("master.node", false) .put(InternalNode.HTTP_ENABLED, true) // for _upgrade - .build()); - } + .build()).get(); client().admin().cluster().prepareHealth("test").setWaitForNodes("" + (numReplicas + 1)); assertAcked(client().admin().indices().prepareUpdateSettings("test").setSettings(ImmutableSettings.builder() .put("number_of_replicas", numReplicas)).execute().actionGet());