|
15 | 15 | import org.elasticsearch.action.admin.cluster.repositories.put.PutRepositoryRequest; |
16 | 16 | import org.elasticsearch.action.admin.cluster.repositories.put.TransportPutRepositoryAction; |
17 | 17 | import org.elasticsearch.action.admin.cluster.repositories.reservedstate.ReservedRepositoryAction; |
| 18 | +import org.elasticsearch.action.admin.cluster.state.ClusterStateRequest; |
18 | 19 | import org.elasticsearch.client.internal.Client; |
19 | 20 | import org.elasticsearch.cluster.ClusterChangedEvent; |
20 | 21 | import org.elasticsearch.cluster.ClusterStateListener; |
| 22 | +import org.elasticsearch.cluster.metadata.RepositoryMetadata; |
21 | 23 | import org.elasticsearch.cluster.metadata.ReservedStateErrorMetadata; |
22 | 24 | import org.elasticsearch.cluster.metadata.ReservedStateHandlerMetadata; |
23 | 25 | import org.elasticsearch.cluster.metadata.ReservedStateMetadata; |
@@ -129,13 +131,15 @@ private void assertClusterStateSaveOK(CountDownLatch savedClusterState, AtomicLo |
129 | 131 | boolean awaitSuccessful = savedClusterState.await(20, TimeUnit.SECONDS); |
130 | 132 | assertTrue(awaitSuccessful); |
131 | 133 |
|
| 134 | + clusterAdmin().state(new ClusterStateRequest(TEST_REQUEST_TIMEOUT).waitForMetadataVersion(metadataVersion.get())).get(); |
| 135 | + |
132 | 136 | final var reposResponse = client().execute( |
133 | 137 | GetRepositoriesAction.INSTANCE, |
134 | 138 | new GetRepositoriesRequest(TEST_REQUEST_TIMEOUT, new String[] { "repo", "repo1" }) |
135 | 139 | ).get(); |
136 | 140 |
|
137 | 141 | assertThat( |
138 | | - reposResponse.repositories().stream().map(r -> r.name()).collect(Collectors.toSet()), |
| 142 | + reposResponse.repositories().stream().map(RepositoryMetadata::name).collect(Collectors.toSet()), |
139 | 143 | containsInAnyOrder("repo", "repo1") |
140 | 144 | ); |
141 | 145 |
|
|
0 commit comments