|
19 | 19 |
|
20 | 20 | package org.elasticsearch.upgrades;
|
21 | 21 |
|
22 |
| -import org.apache.lucene.util.LuceneTestCase.AwaitsFix; |
23 | 22 | import org.elasticsearch.Version;
|
24 | 23 | import org.elasticsearch.action.admin.cluster.settings.ClusterGetSettingsResponse;
|
25 | 24 | import org.elasticsearch.client.Request;
|
|
37 | 36 | import java.util.Collections;
|
38 | 37 |
|
39 | 38 | import static org.elasticsearch.common.xcontent.XContentFactory.jsonBuilder;
|
40 |
| -import static org.elasticsearch.transport.SniffConnectionStrategy.SEARCH_REMOTE_CLUSTERS_SEEDS; |
41 | 39 | import static org.elasticsearch.transport.RemoteClusterService.SEARCH_REMOTE_CLUSTER_SKIP_UNAVAILABLE;
|
| 40 | +import static org.elasticsearch.transport.SniffConnectionStrategy.SEARCH_REMOTE_CLUSTERS_SEEDS; |
42 | 41 | import static org.hamcrest.Matchers.equalTo;
|
43 | 42 |
|
44 |
| -@AwaitsFix(bugUrl = "https://github.com/elastic/elasticsearch/issues/49587") |
45 | 43 | public class FullClusterRestartSettingsUpgradeIT extends AbstractFullClusterRestartTestCase {
|
46 | 44 |
|
47 | 45 | public void testRemoteClusterSettingsUpgraded() throws IOException {
|
@@ -94,10 +92,16 @@ public void testRemoteClusterSettingsUpgraded() throws IOException {
|
94 | 92 | RemoteClusterService.REMOTE_CLUSTER_SKIP_UNAVAILABLE.getConcreteSettingForNamespace("foo").exists(settings));
|
95 | 93 | assertTrue(RemoteClusterService.REMOTE_CLUSTER_SKIP_UNAVAILABLE.getConcreteSettingForNamespace("foo").get(settings));
|
96 | 94 | assertFalse(SEARCH_REMOTE_CLUSTERS_SEEDS.getConcreteSettingForNamespace("foo").exists(settings));
|
97 |
| - assertTrue(SniffConnectionStrategy.REMOTE_CLUSTER_SEEDS.getConcreteSettingForNamespace("foo").exists(settings)); |
| 95 | + assertTrue(SniffConnectionStrategy.REMOTE_CLUSTER_SEEDS_OLD.getConcreteSettingForNamespace("foo").exists(settings)); |
| 96 | + assertFalse(SniffConnectionStrategy.REMOTE_CLUSTER_SEEDS.getConcreteSettingForNamespace("foo").exists(settings)); |
| 97 | + assertTrue(SniffConnectionStrategy.REMOTE_CLUSTER_SEEDS.getConcreteSettingForNamespace("foo") |
| 98 | + .existsOrFallbackExists(settings)); |
98 | 99 | assertThat(
|
99 | 100 | SniffConnectionStrategy.REMOTE_CLUSTER_SEEDS.getConcreteSettingForNamespace("foo").get(settings),
|
100 | 101 | equalTo(Collections.singletonList("localhost:9200")));
|
| 102 | + assertThat( |
| 103 | + SniffConnectionStrategy.REMOTE_CLUSTER_SEEDS_OLD.getConcreteSettingForNamespace("foo").get(settings), |
| 104 | + equalTo(Collections.singletonList("localhost:9200"))); |
101 | 105 | }
|
102 | 106 | }
|
103 | 107 | }
|
|
0 commit comments