|
@@ -55,8 +55,8 @@ public class InternalTestClusterTests extends ESTestCase {
|
|
|
String nodePrefix = randomRealisticUnicodeOfCodepointLengthBetween(1, 10);
|
|
|
|
|
|
Path baseDir = createTempDir();
|
|
|
- InternalTestCluster cluster0 = new InternalTestCluster(InternalTestCluster.configuredNodeMode(), clusterSeed, baseDir, minNumDataNodes, maxNumDataNodes, clusterName, settingsSource, numClientNodes, enableHttpPipelining, nodePrefix);
|
|
|
- InternalTestCluster cluster1 = new InternalTestCluster(InternalTestCluster.configuredNodeMode(), clusterSeed, baseDir, minNumDataNodes, maxNumDataNodes, clusterName, settingsSource, numClientNodes, enableHttpPipelining, nodePrefix);
|
|
|
+ InternalTestCluster cluster0 = new InternalTestCluster("local", clusterSeed, baseDir, minNumDataNodes, maxNumDataNodes, clusterName, settingsSource, numClientNodes, enableHttpPipelining, nodePrefix);
|
|
|
+ InternalTestCluster cluster1 = new InternalTestCluster("local", clusterSeed, baseDir, minNumDataNodes, maxNumDataNodes, clusterName, settingsSource, numClientNodes, enableHttpPipelining, nodePrefix);
|
|
|
assertClusters(cluster0, cluster1, true);
|
|
|
|
|
|
}
|
|
@@ -99,8 +99,8 @@ public class InternalTestClusterTests extends ESTestCase {
|
|
|
String nodePrefix = "foobar";
|
|
|
|
|
|
Path baseDir = createTempDir();
|
|
|
- InternalTestCluster cluster0 = new InternalTestCluster(InternalTestCluster.configuredNodeMode(), clusterSeed, baseDir, minNumDataNodes, maxNumDataNodes, clusterName1, settingsSource, numClientNodes, enableHttpPipelining, nodePrefix);
|
|
|
- InternalTestCluster cluster1 = new InternalTestCluster(InternalTestCluster.configuredNodeMode(), clusterSeed, baseDir, minNumDataNodes, maxNumDataNodes, clusterName2, settingsSource, numClientNodes, enableHttpPipelining, nodePrefix);
|
|
|
+ InternalTestCluster cluster0 = new InternalTestCluster("local", clusterSeed, baseDir, minNumDataNodes, maxNumDataNodes, clusterName1, settingsSource, numClientNodes, enableHttpPipelining, nodePrefix);
|
|
|
+ InternalTestCluster cluster1 = new InternalTestCluster("local", clusterSeed, baseDir, minNumDataNodes, maxNumDataNodes, clusterName2, settingsSource, numClientNodes, enableHttpPipelining, nodePrefix);
|
|
|
|
|
|
assertClusters(cluster0, cluster1, false);
|
|
|
long seed = randomLong();
|
|
@@ -124,7 +124,6 @@ public class InternalTestClusterTests extends ESTestCase {
|
|
|
cluster0.afterTest();
|
|
|
cluster1.afterTest();
|
|
|
} finally {
|
|
|
-
|
|
|
IOUtils.close(cluster0, cluster1);
|
|
|
}
|
|
|
}
|