Skip to content

Commit 9199a06

Browse files
smalyshevSamiul-TheSoccerFan
authored andcommitted
Re-enable and fix the EsqlRestValidationIT test (elastic#128542)
* Re-enable and fix the EsqlRestValidationIT test
1 parent 43453f8 commit 9199a06

File tree

4 files changed

+29
-6
lines changed

4 files changed

+29
-6
lines changed

muted-tests.yml

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -480,8 +480,6 @@ tests:
480480
- class: org.elasticsearch.xpack.esql.plugin.DataNodeRequestSenderIT
481481
method: testSearchWhileRelocating
482482
issue: https://github.com/elastic/elasticsearch/issues/128500
483-
- class: org.elasticsearch.xpack.esql.ccq.EsqlRestValidationIT
484-
issue: https://github.com/elastic/elasticsearch/issues/128543
485483
- class: org.elasticsearch.xpack.ccr.index.engine.FollowingEngineTests
486484
method: testProcessOnceOnPrimary
487485
issue: https://github.com/elastic/elasticsearch/issues/128541

x-pack/plugin/esql/qa/server/multi-clusters/src/javaRestTest/java/org/elasticsearch/xpack/esql/ccq/EsqlRestValidationIT.java

Lines changed: 22 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -81,8 +81,29 @@ private RestClient remoteClusterClient() throws IOException {
8181
return remoteClient;
8282
}
8383

84+
protected boolean isSkipUnavailable() {
85+
return true;
86+
}
87+
88+
@Override
89+
public void testAlias() throws IOException {
90+
assumeFalse("expecting skip_unavailable to be false", isSkipUnavailable());
91+
super.testAlias();
92+
}
93+
94+
@Override
95+
public void testExistentIndexWithoutWildcard() throws IOException {
96+
assumeFalse("expecting skip_unavailable to be false", isSkipUnavailable());
97+
super.testExistentIndexWithoutWildcard();
98+
}
99+
84100
@Before
85101
public void skipTestOnOldVersions() {
86-
assumeTrue("skip on old versions", Clusters.localClusterVersion().equals(Version.V_8_19_0));
102+
Version version = Clusters.localClusterVersion();
103+
assumeTrue(
104+
"skip on old versions",
105+
version.onOrAfter(Version.fromString("9.1.0"))
106+
|| (version.onOrAfter(Version.fromString("8.19.0")) && version.before(Version.fromString("9.0.0")))
107+
);
87108
}
88109
}

x-pack/plugin/esql/qa/server/multi-clusters/src/javaRestTest/java/org/elasticsearch/xpack/esql/ccq/EsqlRestValidationSkipUnFalseIT.java

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -27,4 +27,9 @@ public class EsqlRestValidationSkipUnFalseIT extends EsqlRestValidationIT {
2727
protected String getTestRestCluster() {
2828
return localCluster.getHttpAddresses();
2929
}
30+
31+
@Override
32+
protected boolean isSkipUnavailable() {
33+
return false;
34+
}
3035
}

x-pack/plugin/esql/qa/server/multi-clusters/src/javaRestTest/java/org/elasticsearch/xpack/esql/ccq/RequestIndexFilteringIT.java

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -142,9 +142,8 @@ protected void assertQueryResult(Map<String, Object> result, Matcher<?> columnMa
142142
}
143143

144144
private static boolean checkVersion(org.elasticsearch.Version version) {
145-
return version.onOrAfter(Version.fromString("9.1.0"));
146-
// TODO: enable this when ported to 8.x
147-
// || (version.onOrAfter(Version.fromString("8.19.0")) && version.before(Version.fromString("9.0.0")));
145+
return version.onOrAfter(Version.fromString("9.1.0"))
146+
|| (version.onOrAfter(Version.fromString("8.19.0")) && version.before(Version.fromString("9.0.0")));
148147
}
149148

150149
// We need a separate test since remote missing indices and local missing indices now work differently

0 commit comments

Comments
 (0)