Enable remote lookup join in release (#134400)

* Enable remote lookup join in release

Author: smalyshev

x-pack/plugin/esql/qa/server/multi-clusters/src/javaRestTest/java/org/elasticsearch/xpack/esql/ccq/RequestIndexFilteringIT.java

@@ -157,7 +157,6 @@ private static boolean checkVersion(org.elasticsearch.Version version) {
     }
 
     public void testIndicesDontExistWithRemoteLookupJoin() throws IOException {
-        assumeTrue("Only works with remote LOOKUP JOIN support", EsqlCapabilities.Cap.ENABLE_LOOKUP_JOIN_ON_REMOTE.isEnabled());
         // This check is for "local" cluster - which is different from test runner actually, so it could be old
         assumeTrue(
             "Only works with remote LOOKUP JOIN support",

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

@@ -14,7 +14,6 @@
 import org.elasticsearch.transport.TransportResponse;
 import org.elasticsearch.transport.TransportService;
 import org.elasticsearch.xpack.esql.VerificationException;
-import org.junit.Before;
 
 import java.io.IOException;
 import java.util.List;
@@ -32,11 +31,6 @@ protected boolean reuseClusters() {
         return false;
     }
 
-    @Before
-    public void checkEnabled() {
-        assumeTrue("Remote LOOKUP JOIN not enabled", EsqlCapabilities.Cap.ENABLE_LOOKUP_JOIN_ON_REMOTE.isEnabled());
-    }
-
     public void testLookupFail() throws IOException {
         setupClusters(3);
         populateLookupIndex(LOCAL_CLUSTER, "values_lookup", 10);

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

@@ -16,7 +16,6 @@
 import org.elasticsearch.xpack.core.enrich.action.PutEnrichPolicyAction;
 import org.elasticsearch.xpack.esql.VerificationException;
 import org.elasticsearch.xpack.esql.core.type.DataType;
-import org.junit.Before;
 
 import java.io.IOException;
 import java.time.Duration;
@@ -40,11 +39,6 @@
 // @TestLogging(value = "org.elasticsearch.xpack.esql.session:DEBUG", reason = "to better understand planning")
 public class CrossClusterLookupJoinIT extends AbstractCrossClusterTestCase {
 
-    @Before
-    public void checkEnabled() {
-        assumeTrue("Remote LOOKUP JOIN not enabled", EsqlCapabilities.Cap.ENABLE_LOOKUP_JOIN_ON_REMOTE.isEnabled());
-    }
-
     public void testLookupJoinAcrossClusters() throws IOException {
         setupClustersAndLookups();
 

x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/action/EsqlCapabilities.java

@@ -1285,7 +1285,7 @@ public enum Cap {
         /**
          * Enable support for cross-cluster lookup joins.
          */
-        ENABLE_LOOKUP_JOIN_ON_REMOTE(Build.current().isSnapshot()),
+        ENABLE_LOOKUP_JOIN_ON_REMOTE,
 
         /**
          * Fix the planning of {@code | ENRICH _remote:policy} when there's a preceding {@code | LOOKUP JOIN},

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

@@ -2354,22 +2354,6 @@ public void testFullTextFunctionsInStats() {
         }
     }
 
-    public void testRemoteLookupJoinIsSnapshot() {
-        // TODO: remove when we allow remote joins in release builds
-        assumeTrue("Remote LOOKUP JOIN not enabled", EsqlCapabilities.Cap.ENABLE_LOOKUP_JOIN_ON_REMOTE.isEnabled());
-        assertTrue(Build.current().isSnapshot());
-    }
-
-    public void testRemoteLookupJoinIsDisabled() {
-        // TODO: remove when we allow remote joins in release builds
-        assumeFalse("Remote LOOKUP JOIN enabled", EsqlCapabilities.Cap.ENABLE_LOOKUP_JOIN_ON_REMOTE.isEnabled());
-        ParsingException e = expectThrows(
-            ParsingException.class,
-            () -> query("FROM test,remote:test | EVAL language_code = languages | LOOKUP JOIN languages_lookup ON language_code")
-        );
-        assertThat(e.getMessage(), containsString("remote clusters are not supported with LOOKUP JOIN"));
-    }
-
     public void testDecayFunctionNullArgs() {
         assumeTrue("Decay function not enabled", EsqlCapabilities.Cap.DECAY_FUNCTION.isEnabled());
 

x-pack/plugin/esql/src/test/java/org/elasticsearch/xpack/esql/optimizer/OptimizerVerificationTests.java

@@ -318,7 +318,6 @@ public void testRemoteEnrichAfterLookupJoin() {
     }
 
     public void testRemoteLookupJoinWithPipelineBreaker() {
-        assumeTrue("Remote LOOKUP JOIN not enabled", EsqlCapabilities.Cap.ENABLE_LOOKUP_JOIN_ON_REMOTE.isEnabled());
         var analyzer = AnalyzerTestUtils.analyzer(loadMapping("mapping-default.json", "test,remote:test"));
         assertEquals(
             "1:92: LOOKUP JOIN with remote indices can't be executed after [STATS c = COUNT(*) by languages]@1:25",

x-pack/plugin/esql/src/test/java/org/elasticsearch/xpack/esql/parser/StatementParserTests.java

@@ -3271,7 +3271,6 @@ public void testInvalidPatternsWithIntermittentQuotes() {
     }
 
     public void testValidJoinPatternWithRemote() {
-        assumeTrue("LOOKUP JOIN requires corresponding capability", EsqlCapabilities.Cap.ENABLE_LOOKUP_JOIN_ON_REMOTE.isEnabled());
         var fromPatterns = randomIndexPatterns(CROSS_CLUSTER);
         var joinPattern = randomIndexPattern(without(CROSS_CLUSTER), without(WILDCARD_PATTERN), without(INDEX_SELECTOR));
         var plan = statement("FROM " + fromPatterns + " | LOOKUP JOIN " + joinPattern + " ON " + randomIdentifier());