Use right capability check for FORK with CCS (#134428)

ioanatia · web-flow · commit ecf7eae2602f · 2025-09-10T11:37:24.000+02:00
diff --git a/x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/parser/LogicalPlanBuilder.java b/x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/parser/LogicalPlanBuilder.java
@@ -753,7 +753,7 @@ public PlanFactory visitForkCommand(EsqlBaseParser.ForkCommandContext ctx) {
         }
 
         return input -> {
-            if (EsqlCapabilities.Cap.ENABLE_LOOKUP_JOIN_ON_REMOTE.isEnabled() == false) {
+            if (EsqlCapabilities.Cap.ENABLE_FORK_FOR_REMOTE_INDICES.isEnabled() == false) {
                 checkForRemoteClusters(input, source(ctx), "FORK");
             }
             List<LogicalPlan> subPlans = subQueries.stream().map(planFactory -> planFactory.apply(input)).toList();

Original file line number	Diff line number	Diff line change
`@@ -753,7 +753,7 @@ public PlanFactory visitForkCommand(EsqlBaseParser.ForkCommandContext ctx) {`
`753`	`753`	`}`
`754`	`754`
`755`	`755`	`return input -> {`
`756`		`- if (EsqlCapabilities.Cap.ENABLE_LOOKUP_JOIN_ON_REMOTE.isEnabled() == false) {`
	`756`	`+ if (EsqlCapabilities.Cap.ENABLE_FORK_FOR_REMOTE_INDICES.isEnabled() == false) {`
`757`	`757`	`checkForRemoteClusters(input, source(ctx), "FORK");`
`758`	`758`	`}`
`759`	`759`	`List<LogicalPlan> subPlans = subQueries.stream().map(planFactory -> planFactory.apply(input)).toList();`