Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 0 additions & 2 deletions muted-tests.yml
Original file line number Diff line number Diff line change
Expand Up @@ -486,8 +486,6 @@ tests:
- class: org.elasticsearch.xpack.esql.plugin.DataNodeRequestSenderIT
method: testSearchWhileRelocating
issue: https://github.com/elastic/elasticsearch/issues/128500
- class: org.elasticsearch.xpack.esql.ccq.EsqlRestValidationIT
issue: https://github.com/elastic/elasticsearch/issues/128543
- class: org.elasticsearch.xpack.ccr.index.engine.FollowingEngineTests
method: testProcessOnceOnPrimary
issue: https://github.com/elastic/elasticsearch/issues/128541
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -81,8 +81,29 @@ private RestClient remoteClusterClient() throws IOException {
return remoteClient;
}

protected boolean isSkipUnavailable() {
return true;
}

@Override
public void testAlias() throws IOException {
assumeFalse("expecting skip_unavailable to be false", isSkipUnavailable());
super.testAlias();
}

@Override
public void testExistentIndexWithoutWildcard() throws IOException {
assumeFalse("expecting skip_unavailable to be false", isSkipUnavailable());
super.testExistentIndexWithoutWildcard();
}

@Before
public void skipTestOnOldVersions() {
assumeTrue("skip on old versions", Clusters.localClusterVersion().equals(Version.V_8_19_0));
Version version = Clusters.localClusterVersion();
assumeTrue(
"skip on old versions",
version.onOrAfter(Version.fromString("9.1.0"))
|| (version.onOrAfter(Version.fromString("8.19.0")) && version.before(Version.fromString("9.0.0")))
);
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -27,4 +27,9 @@ public class EsqlRestValidationSkipUnFalseIT extends EsqlRestValidationIT {
protected String getTestRestCluster() {
return localCluster.getHttpAddresses();
}

@Override
protected boolean isSkipUnavailable() {
return false;
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -142,9 +142,8 @@ protected void assertQueryResult(Map<String, Object> result, Matcher<?> columnMa
}

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

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