diff options
Diffstat (limited to 'core/src/test/java/org/elasticsearch/cluster/ClusterServiceIT.java')
-rw-r--r-- | core/src/test/java/org/elasticsearch/cluster/ClusterServiceIT.java | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/core/src/test/java/org/elasticsearch/cluster/ClusterServiceIT.java b/core/src/test/java/org/elasticsearch/cluster/ClusterServiceIT.java index 2d781c866d..cc3cae8606 100644 --- a/core/src/test/java/org/elasticsearch/cluster/ClusterServiceIT.java +++ b/core/src/test/java/org/elasticsearch/cluster/ClusterServiceIT.java @@ -35,6 +35,7 @@ import org.elasticsearch.common.inject.Singleton; import org.elasticsearch.common.settings.Settings; import org.elasticsearch.common.unit.TimeValue; import org.elasticsearch.discovery.zen.ZenDiscovery; +import org.elasticsearch.node.Node; import org.elasticsearch.plugins.Plugin; import org.elasticsearch.test.ESIntegTestCase; import org.elasticsearch.test.ESIntegTestCase.ClusterScope; @@ -305,7 +306,7 @@ public class ClusterServiceIT extends ESIntegTestCase { .build(); InternalTestCluster.Async<String> master = internalCluster().startNodeAsync(settings); - InternalTestCluster.Async<String> nonMaster = internalCluster().startNodeAsync(settingsBuilder().put(settings).put("node.master", false).build()); + InternalTestCluster.Async<String> nonMaster = internalCluster().startNodeAsync(settingsBuilder().put(settings).put(Node.NODE_MASTER_SETTING.getKey(), false).build()); master.get(); ensureGreen(); // make sure we have a cluster @@ -631,7 +632,7 @@ public class ClusterServiceIT extends ESIntegTestCase { controlSources = new HashSet<>(Arrays.asList("1", "2", "3", "4", "5")); for (PendingClusterTask task : response) { if (controlSources.remove(task.getSource().string())) { - assertThat(task.getTimeInQueueInMillis(), greaterThan(0l)); + assertThat(task.getTimeInQueueInMillis(), greaterThan(0L)); } } assertTrue(controlSources.isEmpty()); @@ -642,7 +643,7 @@ public class ClusterServiceIT extends ESIntegTestCase { Settings settings = settingsBuilder() .put("discovery.type", "zen") .put("discovery.zen.minimum_master_nodes", 1) - .put(ZenDiscovery.SETTING_PING_TIMEOUT, "400ms") + .put(ZenDiscovery.PING_TIMEOUT_SETTING.getKey(), "400ms") .put("discovery.initial_state_timeout", "500ms") .build(); |