Skip to content

Commit 378fc00

Browse files
committed
Remove verifier ban
1 parent 8fa80a9 commit 378fc00

File tree

2 files changed

+3
-8
lines changed
  • x-pack/plugin/esql/src

2 files changed

+3
-8
lines changed

x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/plan/logical/Enrich.java

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -317,8 +317,6 @@ private static void checkForPlansForbiddenBeforeRemoteEnrich(Enrich enrich, Fail
317317
badCommands.add("STATS");
318318
} else if (u instanceof Enrich upstreamEnrich && upstreamEnrich.mode() == Enrich.Mode.COORDINATOR) {
319319
badCommands.add("another ENRICH with coordinator policy");
320-
} else if (u instanceof LookupJoin) {
321-
badCommands.add("LOOKUP JOIN");
322320
} else if (u instanceof Fork) {
323321
badCommands.add("FORK");
324322
}

x-pack/plugin/esql/src/test/java/org/elasticsearch/xpack/esql/analysis/VerifierTests.java

Lines changed: 3 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -2424,32 +2424,29 @@ public void testRemoteEnrichAfterLookupJoin() {
24242424
| %s
24252425
""", lookupCommand), analyzer);
24262426

2427-
String err = error(Strings.format("""
2427+
query(Strings.format("""
24282428
FROM test
24292429
| EVAL language_code = languages
24302430
| %s
24312431
| ENRICH _remote:languages ON language_code
24322432
""", lookupCommand), analyzer);
2433-
assertThat(err, containsString("4:3: ENRICH with remote policy can't be executed after LOOKUP JOIN"));
24342433

2435-
err = error(Strings.format("""
2434+
query(Strings.format("""
24362435
FROM test
24372436
| EVAL language_code = languages
24382437
| %s
24392438
| ENRICH _remote:languages ON language_code
24402439
| %s
24412440
""", lookupCommand, lookupCommand), analyzer);
2442-
assertThat(err, containsString("4:3: ENRICH with remote policy can't be executed after LOOKUP JOIN"));
24432441

2444-
err = error(Strings.format("""
2442+
query(Strings.format("""
24452443
FROM test
24462444
| EVAL language_code = languages
24472445
| %s
24482446
| EVAL x = 1
24492447
| MV_EXPAND language_code
24502448
| ENRICH _remote:languages ON language_code
24512449
""", lookupCommand), analyzer);
2452-
assertThat(err, containsString("6:3: ENRICH with remote policy can't be executed after LOOKUP JOIN"));
24532450
}
24542451

24552452
public void testRemoteEnrichAfterCoordinatorOnlyPlans() {

0 commit comments

Comments
 (0)