|
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