diff --git a/muted-tests.yml b/muted-tests.yml index ac99142aaed56..2d3b339f29374 100644 --- a/muted-tests.yml +++ b/muted-tests.yml @@ -354,9 +354,6 @@ tests: - class: org.elasticsearch.search.SearchWithRejectionsIT method: testOpenContextsAfterRejections issue: https://github.com/elastic/elasticsearch/issues/130821 -- class: org.elasticsearch.xpack.esql.ccq.MultiClustersIT - method: testLookupJoinAliases - issue: https://github.com/elastic/elasticsearch/issues/131166 - class: org.elasticsearch.packaging.test.DockerTests method: test090SecurityCliPackaging issue: https://github.com/elastic/elasticsearch/issues/131107 @@ -408,9 +405,6 @@ tests: - class: org.elasticsearch.compute.lucene.read.SortedSetOrdinalsBuilderTests method: testReader issue: https://github.com/elastic/elasticsearch/issues/131573 -- class: org.elasticsearch.xpack.esql.ccq.MultiClustersIT - method: testLookupJoinAliasesSkipOld - issue: https://github.com/elastic/elasticsearch/issues/131697 - class: org.elasticsearch.packaging.test.DockerTests method: test151MachineDependentHeapWithSizeOverride issue: https://github.com/elastic/elasticsearch/issues/123437 diff --git a/x-pack/plugin/esql/qa/server/multi-clusters/src/javaRestTest/java/org/elasticsearch/xpack/esql/ccq/MultiClustersIT.java b/x-pack/plugin/esql/qa/server/multi-clusters/src/javaRestTest/java/org/elasticsearch/xpack/esql/ccq/MultiClustersIT.java index af6915a717d3a..42b7bc59e278b 100644 --- a/x-pack/plugin/esql/qa/server/multi-clusters/src/javaRestTest/java/org/elasticsearch/xpack/esql/ccq/MultiClustersIT.java +++ b/x-pack/plugin/esql/qa/server/multi-clusters/src/javaRestTest/java/org/elasticsearch/xpack/esql/ccq/MultiClustersIT.java @@ -127,9 +127,13 @@ private void setupLookupIndices() throws IOException { "morecolor": { "type": "keyword" } } """; - var lookupDocs = IntStream.range(0, between(1, 5)) - .mapToObj(n -> new Doc(n, randomFrom("red", "yellow", "green"), randomIntBetween(1, 1000))) - .toList(); + var randomDocsData = new ArrayList(); + var lookupDocs = IntStream.range(0, between(1, 5)).mapToObj(n -> { + String color = randomFrom("red", "yellow", "green"); + int data = randomValueOtherThanMany(i -> randomDocsData.contains(i), () -> randomIntBetween(1, 1000)); + randomDocsData.add(data); + return new Doc(n, color, data); + }).toList(); createIndex( localClient, lookupIndexLocal,