10
10
import org .elasticsearch .action .admin .cluster .remote .RemoteInfoRequest ;
11
11
import org .elasticsearch .action .admin .cluster .settings .ClusterUpdateSettingsRequest ;
12
12
import org .elasticsearch .common .settings .Settings ;
13
+ import org .elasticsearch .common .unit .TimeValue ;
13
14
import org .elasticsearch .common .xcontent .XContentType ;
14
15
import org .elasticsearch .transport .RemoteConnectionInfo ;
15
16
import org .elasticsearch .transport .RemoteConnectionStrategy ;
@@ -93,7 +94,7 @@ public void testFollowIndex() throws Exception {
93
94
}
94
95
95
96
private void setupRemoteCluster () throws Exception {
96
- ClusterUpdateSettingsRequest updateSettingsRequest = new ClusterUpdateSettingsRequest ();
97
+ ClusterUpdateSettingsRequest updateSettingsRequest = new ClusterUpdateSettingsRequest (). masterNodeTimeout ( TimeValue . MAX_VALUE ) ;
97
98
String address = getLeaderCluster ().getMasterNodeInstance (TransportService .class ).boundAddress ().publishAddress ().toString ();
98
99
updateSettingsRequest .persistentSettings (Settings .builder ().put ("cluster.remote.leader_cluster.seeds" , address ));
99
100
assertAcked (followerClient ().admin ().cluster ().updateSettings (updateSettingsRequest ).actionGet ());
@@ -104,7 +105,7 @@ private void setupRemoteCluster() throws Exception {
104
105
}
105
106
106
107
private void cleanRemoteCluster () throws Exception {
107
- ClusterUpdateSettingsRequest updateSettingsRequest = new ClusterUpdateSettingsRequest ();
108
+ ClusterUpdateSettingsRequest updateSettingsRequest = new ClusterUpdateSettingsRequest (). masterNodeTimeout ( TimeValue . MAX_VALUE ) ;
108
109
updateSettingsRequest .persistentSettings (Settings .builder ().put ("cluster.remote.leader_cluster.seeds" , (String ) null ));
109
110
assertAcked (followerClient ().admin ().cluster ().updateSettings (updateSettingsRequest ).actionGet ());
110
111
0 commit comments