honeymoose
/
OpenSearch
mirror of https://github.com/honeymoose/OpenSearch.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Use clear cluster names in order to make debugging easier. 

Relates to #37681
This commit is contained in:
Martijn van Groningen 2019-02-12 10:18:52 +01:00
parent c7cdd6a46a
commit 6290d59ffa
No known key found for this signature in database
GPG Key ID: AB236F4FCF2AF12A
1 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
x-pack/plugin/ccr/src/test/java/org/elasticsearch/xpack/CcrIntegTestCase.java
View File

@ -34,7 +34,6 @@ import org.elasticsearch.cluster.service.ClusterService;
import org.elasticsearch.common.Priority; import org.elasticsearch.common.Priority;
import org.elasticsearch.common.Randomness; import org.elasticsearch.common.Randomness;
import org.elasticsearch.common.Strings; import org.elasticsearch.common.Strings;
import org.elasticsearch.common.UUIDs;
import org.elasticsearch.common.bytes.BytesReference; import org.elasticsearch.common.bytes.BytesReference;
import org.elasticsearch.common.network.NetworkModule; import org.elasticsearch.common.network.NetworkModule;
import org.elasticsearch.common.settings.Settings; import org.elasticsearch.common.settings.Settings;
@ -128,7 +127,7 @@ public abstract class CcrIntegTestCase extends ESTestCase {
MockNioTransportPlugin.class); MockNioTransportPlugin.class);
InternalTestCluster leaderCluster = new InternalTestCluster(randomLong(), createTempDir(), true, true, numberOfNodesPerCluster(), InternalTestCluster leaderCluster = new InternalTestCluster(randomLong(), createTempDir(), true, true, numberOfNodesPerCluster(),
numberOfNodesPerCluster(), UUIDs.randomBase64UUID(random()), createNodeConfigurationSource(null), 0, "leader", mockPlugins, numberOfNodesPerCluster(), "leader_cluster", createNodeConfigurationSource(null), 0, "leader", mockPlugins,
Function.identity()); Function.identity());
leaderCluster.beforeTest(random(), 0.0D); leaderCluster.beforeTest(random(), 0.0D);
leaderCluster.ensureAtLeastNumDataNodes(numberOfNodesPerCluster()); leaderCluster.ensureAtLeastNumDataNodes(numberOfNodesPerCluster());
@ -139,7 +138,7 @@ public abstract class CcrIntegTestCase extends ESTestCase {
String address = leaderCluster.getDataNodeInstance(TransportService.class).boundAddress().publishAddress().toString(); String address = leaderCluster.getDataNodeInstance(TransportService.class).boundAddress().publishAddress().toString();
InternalTestCluster followerCluster = new InternalTestCluster(randomLong(), createTempDir(), true, true, numberOfNodesPerCluster(), InternalTestCluster followerCluster = new InternalTestCluster(randomLong(), createTempDir(), true, true, numberOfNodesPerCluster(),
numberOfNodesPerCluster(), UUIDs.randomBase64UUID(random()), createNodeConfigurationSource(address), 0, "follower", numberOfNodesPerCluster(), "follower_cluster", createNodeConfigurationSource(address), 0, "follower",
mockPlugins, Function.identity()); mockPlugins, Function.identity());
clusterGroup = new ClusterGroup(leaderCluster, followerCluster); clusterGroup = new ClusterGroup(leaderCluster, followerCluster);