github-mirrors/elasticsearch
1
0
Fork 0
mirror of https://github.com/elastic/elasticsearch.git synced 2025-06-30 02:13:33 -04:00
Code Issues Projects Releases Packages Wiki Activity

Fix TimeSeriesLifecycleActionsIT

Browse source
This commit is contained in:
Andrei Dan 2020-04-06 22:17:22 +01:00
parent 48cbca1de4
commit 50186b2580
1 changed files with 8 additions and 12 deletions
Download patch file Download diff file Expand all files Collapse all files

20
x-pack/plugin/ilm/qa/multi-node/src/test/java/org/elasticsearch/xpack/ilm/TimeSeriesLifecycleActionsIT.java
View file

@ -1697,18 +1697,14 @@ public class TimeSeriesLifecycleActionsIT extends ESRestTestCase {
try (InputStream is = getSnapshotsResponse.getEntity().getContent()) {
snapshotsResponseMap = XContentHelper.convertToMap(XContentType.JSON.xContent(), is, true);
}
ArrayList<Object> responses = (ArrayList<Object>) snapshotsResponseMap.get("responses");
for (Object response : responses) {
Map<String, Object> responseAsMap = (Map<String, Object>) response;
if (responseAsMap.get("snapshots") != null) {
ArrayList<Object> snapshots = (ArrayList<Object>) responseAsMap.get("snapshots");
for (Object snapshot : snapshots) {
Map<String, Object> snapshotInfoMap = (Map<String, Object>) snapshot;
if (snapshotInfoMap.get("snapshot").equals(snapshotName[0]) &&
// wait for the snapshot to be completed (successfully or not) otherwise the teardown might fail
SnapshotState.valueOf((String) snapshotInfoMap.get("state")).completed()) {
return true;
}
if (snapshotsResponseMap.get("snapshots") != null) {
ArrayList<Object> snapshots = (ArrayList<Object>) snapshotsResponseMap.get("snapshots");
for (Object snapshot : snapshots) {
Map<String, Object> snapshotInfoMap = (Map<String, Object>) snapshot;
if (snapshotInfoMap.get("snapshot").equals(snapshotName[0]) &&
// wait for the snapshot to be completed (successfully or not) otherwise the teardown might fail
SnapshotState.valueOf((String) snapshotInfoMap.get("state")).completed()) {
return true;
}
}
}