Skip to content

Commit a1e95bd

Browse files
inline assertion
1 parent c42c0f8 commit a1e95bd

File tree

1 file changed

+2
-5
lines changed

1 file changed

+2
-5
lines changed

x-pack/plugin/esql/src/internalClusterTest/java/org/elasticsearch/xpack/esql/action/CrossClusterLookupJoinIT.java

Lines changed: 2 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -288,17 +288,14 @@ public void testLookupJoinMissingLocalIndexAfterPipelineBreaker() throws IOExcep
288288
setupClusters(2);
289289
populateLookupIndex(REMOTE_CLUSTER_1, "values_lookup", 10);
290290

291-
var ex = expectThrows(
291+
expectThrows(
292292
VerificationException.class,
293+
containsString("LOOKUP JOIN with remote indices can't be executed after [STATS lookup_key = max(lookup_key)]"),
293294
() -> runQuery(
294295
"FROM c*:logs-* | EVAL lookup_key = v | STATS lookup_key = max(lookup_key) | LOOKUP JOIN values_lookup ON lookup_key",
295296
randomBoolean()
296297
)
297298
);
298-
assertThat(
299-
ex.getMessage(),
300-
containsString("LOOKUP JOIN with remote indices can't be executed after [STATS lookup_key = max(lookup_key)]")
301-
);
302299
}
303300

304301
public void testLookupJoinMissingKey() throws IOException {

0 commit comments

Comments
 (0)