diff options
Diffstat (limited to 'core/src/test/java/org/elasticsearch/discovery/zen/ZenDiscoveryIT.java')
-rw-r--r-- | core/src/test/java/org/elasticsearch/discovery/zen/ZenDiscoveryIT.java | 19 |
1 files changed, 10 insertions, 9 deletions
diff --git a/core/src/test/java/org/elasticsearch/discovery/zen/ZenDiscoveryIT.java b/core/src/test/java/org/elasticsearch/discovery/zen/ZenDiscoveryIT.java index 9f9c0420c2..6c564a9774 100644 --- a/core/src/test/java/org/elasticsearch/discovery/zen/ZenDiscoveryIT.java +++ b/core/src/test/java/org/elasticsearch/discovery/zen/ZenDiscoveryIT.java @@ -45,6 +45,7 @@ import org.elasticsearch.discovery.zen.elect.ElectMasterService; import org.elasticsearch.discovery.zen.fd.FaultDetection; import org.elasticsearch.discovery.zen.membership.MembershipAction; import org.elasticsearch.discovery.zen.publish.PublishClusterStateAction; +import org.elasticsearch.node.Node; import org.elasticsearch.test.ESIntegTestCase; import org.elasticsearch.test.TestCustomMetaData; import org.elasticsearch.test.junit.annotations.TestLogging; @@ -77,6 +78,7 @@ import static org.hamcrest.Matchers.sameInstance; @ESIntegTestCase.ClusterScope(scope = ESIntegTestCase.Scope.TEST, numDataNodes = 0, numClientNodes = 0) @ESIntegTestCase.SuppressLocalMode +@TestLogging("_root:DEBUG") public class ZenDiscoveryIT extends ESIntegTestCase { public void testChangeRejoinOnMasterOptionIsDynamic() throws Exception { Settings nodeSettings = Settings.settingsBuilder() @@ -95,18 +97,18 @@ public class ZenDiscoveryIT extends ESIntegTestCase { public void testNoShardRelocationsOccurWhenElectedMasterNodeFails() throws Exception { Settings defaultSettings = Settings.builder() - .put(FaultDetection.SETTING_PING_TIMEOUT, "1s") - .put(FaultDetection.SETTING_PING_RETRIES, "1") + .put(FaultDetection.PING_TIMEOUT_SETTING.getKey(), "1s") + .put(FaultDetection.PING_RETRIES_SETTING.getKey(), "1") .put("discovery.type", "zen") .build(); Settings masterNodeSettings = Settings.builder() - .put("node.data", false) + .put(Node.NODE_DATA_SETTING.getKey(), false) .put(defaultSettings) .build(); internalCluster().startNodesAsync(2, masterNodeSettings).get(); Settings dateNodeSettings = Settings.builder() - .put("node.master", false) + .put(Node.NODE_MASTER_SETTING.getKey(), false) .put(defaultSettings) .build(); internalCluster().startNodesAsync(2, dateNodeSettings).get(); @@ -139,21 +141,20 @@ public class ZenDiscoveryIT extends ESIntegTestCase { assertThat(numRecoveriesAfterNewMaster, equalTo(numRecoveriesBeforeNewMaster)); } - @TestLogging(value = "action.admin.cluster.health:TRACE") public void testNodeFailuresAreProcessedOnce() throws ExecutionException, InterruptedException, IOException { Settings defaultSettings = Settings.builder() - .put(FaultDetection.SETTING_PING_TIMEOUT, "1s") - .put(FaultDetection.SETTING_PING_RETRIES, "1") + .put(FaultDetection.PING_TIMEOUT_SETTING.getKey(), "1s") + .put(FaultDetection.PING_RETRIES_SETTING.getKey(), "1") .put("discovery.type", "zen") .build(); Settings masterNodeSettings = Settings.builder() - .put("node.data", false) + .put(Node.NODE_DATA_SETTING.getKey(), false) .put(defaultSettings) .build(); String master = internalCluster().startNode(masterNodeSettings); Settings dateNodeSettings = Settings.builder() - .put("node.master", false) + .put(Node.NODE_MASTER_SETTING.getKey(), false) .put(defaultSettings) .build(); internalCluster().startNodesAsync(2, dateNodeSettings).get(); |