|
23 | 23 | import org.elasticsearch.action.index.IndexResponse;
|
24 | 24 | import org.elasticsearch.common.settings.Settings;
|
25 | 25 | import org.elasticsearch.discovery.DiscoverySettings;
|
26 |
| -import org.elasticsearch.discovery.zen.ElectMasterService; |
27 | 26 | import org.elasticsearch.discovery.zen.FaultDetection;
|
28 | 27 | import org.elasticsearch.plugins.Plugin;
|
29 | 28 | import org.elasticsearch.test.ESIntegTestCase;
|
@@ -72,12 +71,12 @@ public void testMasterFailoverDuringIndexingWithMappingChanges() throws Throwabl
|
72 | 71 | final Settings sharedSettings = Settings.builder()
|
73 | 72 | .put(FaultDetection.PING_TIMEOUT_SETTING.getKey(), "1s") // for hitting simulated network failures quickly
|
74 | 73 | .put(FaultDetection.PING_RETRIES_SETTING.getKey(), "1") // for hitting simulated network failures quickly
|
75 |
| - .put(TestZenDiscovery.USE_ZEN2.getKey(), false) |
76 |
| - .put("discovery.zen.join_timeout", "10s") // still long to induce failures but to long so test won't time out |
| 74 | + .put("cluster.join.timeout", "10s") // still long to induce failures but not too long so test won't time out |
77 | 75 | .put(DiscoverySettings.PUBLISH_TIMEOUT_SETTING.getKey(), "1s") // <-- for hitting simulated network failures quickly
|
78 |
| - .put(ElectMasterService.DISCOVERY_ZEN_MINIMUM_MASTER_NODES_SETTING.getKey(), 2) |
79 | 76 | .build();
|
80 | 77 |
|
| 78 | + internalCluster().setBootstrapMasterNodeIndex(2); |
| 79 | + |
81 | 80 | internalCluster().startMasterOnlyNodes(3, sharedSettings);
|
82 | 81 |
|
83 | 82 | String dataNode = internalCluster().startDataOnlyNode(sharedSettings);
|
|
0 commit comments