|
@@ -10,6 +10,7 @@ import org.elasticsearch.action.admin.cluster.remote.RemoteInfoAction;
|
|
|
import org.elasticsearch.action.admin.cluster.remote.RemoteInfoRequest;
|
|
|
import org.elasticsearch.action.admin.cluster.settings.ClusterUpdateSettingsRequest;
|
|
|
import org.elasticsearch.common.settings.Settings;
|
|
|
+import org.elasticsearch.common.unit.TimeValue;
|
|
|
import org.elasticsearch.common.xcontent.XContentType;
|
|
|
import org.elasticsearch.transport.RemoteConnectionInfo;
|
|
|
import org.elasticsearch.transport.RemoteConnectionStrategy;
|
|
@@ -93,7 +94,7 @@ public class RestartIndexFollowingIT extends CcrIntegTestCase {
|
|
|
}
|
|
|
|
|
|
private void setupRemoteCluster() throws Exception {
|
|
|
- ClusterUpdateSettingsRequest updateSettingsRequest = new ClusterUpdateSettingsRequest();
|
|
|
+ ClusterUpdateSettingsRequest updateSettingsRequest = new ClusterUpdateSettingsRequest().masterNodeTimeout(TimeValue.MAX_VALUE);
|
|
|
String address = getLeaderCluster().getMasterNodeInstance(TransportService.class).boundAddress().publishAddress().toString();
|
|
|
updateSettingsRequest.persistentSettings(Settings.builder().put("cluster.remote.leader_cluster.seeds", address));
|
|
|
assertAcked(followerClient().admin().cluster().updateSettings(updateSettingsRequest).actionGet());
|
|
@@ -104,7 +105,7 @@ public class RestartIndexFollowingIT extends CcrIntegTestCase {
|
|
|
}
|
|
|
|
|
|
private void cleanRemoteCluster() throws Exception {
|
|
|
- ClusterUpdateSettingsRequest updateSettingsRequest = new ClusterUpdateSettingsRequest();
|
|
|
+ ClusterUpdateSettingsRequest updateSettingsRequest = new ClusterUpdateSettingsRequest().masterNodeTimeout(TimeValue.MAX_VALUE);
|
|
|
updateSettingsRequest.persistentSettings(Settings.builder().put("cluster.remote.leader_cluster.seeds", (String) null));
|
|
|
assertAcked(followerClient().admin().cluster().updateSettings(updateSettingsRequest).actionGet());
|
|
|
|