Skip to content

Commit b11436a

Browse files
committed
Take into account that .ml-state-write alias may be attached to .ml-state when the aliases are made hidden
1 parent 428a22b commit b11436a

File tree

1 file changed

+21
-13
lines changed

1 file changed

+21
-13
lines changed

x-pack/qa/full-cluster-restart/src/test/java/org/elasticsearch/xpack/restart/MlHiddenIndicesFullClusterRestartIT.java

Lines changed: 21 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -40,13 +40,13 @@
4040
public class MlHiddenIndicesFullClusterRestartIT extends AbstractFullClusterRestartTestCase {
4141

4242
private static final String JOB_ID = "ml-hidden-indices-old-cluster-job";
43-
private static final List<Tuple<String, String>> EXPECTED_INDEX_ALIAS_PAIRS =
43+
private static final List<Tuple<List<String>, String>> EXPECTED_INDEX_ALIAS_PAIRS =
4444
List.of(
45-
Tuple.tuple(".ml-annotations-6", ".ml-annotations-read"),
46-
Tuple.tuple(".ml-annotations-6", ".ml-annotations-write"),
47-
Tuple.tuple(".ml-state-000001", ".ml-state-write"),
48-
Tuple.tuple(".ml-anomalies-shared", ".ml-anomalies-" + JOB_ID),
49-
Tuple.tuple(".ml-anomalies-shared", ".ml-anomalies-.write-" + JOB_ID)
45+
Tuple.tuple(List.of(".ml-annotations-6"), ".ml-annotations-read"),
46+
Tuple.tuple(List.of(".ml-annotations-6"), ".ml-annotations-write"),
47+
Tuple.tuple(List.of(".ml-state", ".ml-state-000001"), ".ml-state-write"),
48+
Tuple.tuple(List.of(".ml-anomalies-shared"), ".ml-anomalies-" + JOB_ID),
49+
Tuple.tuple(List.of(".ml-anomalies-shared"), ".ml-anomalies-.write-" + JOB_ID)
5050
);
5151

5252
@Override
@@ -88,11 +88,15 @@ public void testMlIndicesBecomeHidden() throws Exception {
8888
is(nullValue()));
8989
}
9090

91-
for (Tuple<String, String> indexAndAlias : EXPECTED_INDEX_ALIAS_PAIRS) {
92-
assertThat(
93-
indexAndAlias + " expected not be hidden but was, aliasesMap = " + aliasesMap,
94-
XContentMapValues.extractValue(aliasesMap, indexAndAlias.v1(), "aliases", indexAndAlias.v2(), "is_hidden"),
95-
is(nullValue()));
91+
for (Tuple<List<String>, String> indexAndAlias : EXPECTED_INDEX_ALIAS_PAIRS) {
92+
List<String> indices = indexAndAlias.v1();
93+
String alias = indexAndAlias.v2();
94+
for (String index : indices) {
95+
assertThat(
96+
indexAndAlias + " expected not be hidden but was, aliasesMap = " + aliasesMap,
97+
XContentMapValues.extractValue(aliasesMap, index, "aliases", alias, "is_hidden"),
98+
is(nullValue()));
99+
}
96100
}
97101
}
98102
} else {
@@ -110,10 +114,14 @@ public void testMlIndicesBecomeHidden() throws Exception {
110114
is(equalTo("true")));
111115
}
112116

113-
for (Tuple<String, String> indexAndAlias : EXPECTED_INDEX_ALIAS_PAIRS) {
117+
for (Tuple<List<String>, String> indexAndAlias : EXPECTED_INDEX_ALIAS_PAIRS) {
118+
List<String> indices = indexAndAlias.v1();
119+
String alias = indexAndAlias.v2();
114120
assertThat(
115121
indexAndAlias + " expected to be hidden but wasn't, aliasesMap = " + aliasesMap,
116-
XContentMapValues.extractValue(aliasesMap, indexAndAlias.v1(), "aliases", indexAndAlias.v2(), "is_hidden"),
122+
indices.stream()
123+
.anyMatch(index ->
124+
Boolean.TRUE.equals(XContentMapValues.extractValue(aliasesMap, index, "aliases", alias, "is_hidden"))),
117125
is(true));
118126
}
119127
}

0 commit comments

Comments
 (0)