diff --git a/x-pack/plugin/esql/src/internalClusterTest/java/org/elasticsearch/xpack/esql/action/LookupJoinTypesIT.java b/x-pack/plugin/esql/src/internalClusterTest/java/org/elasticsearch/xpack/esql/action/LookupJoinTypesIT.java index 4070e11120ab9..fdf82bc73349d 100644 --- a/x-pack/plugin/esql/src/internalClusterTest/java/org/elasticsearch/xpack/esql/action/LookupJoinTypesIT.java +++ b/x-pack/plugin/esql/src/internalClusterTest/java/org/elasticsearch/xpack/esql/action/LookupJoinTypesIT.java @@ -54,6 +54,7 @@ import static org.elasticsearch.xpack.esql.core.type.DataType.SHORT; import static org.elasticsearch.xpack.esql.core.type.DataType.TEXT; import static org.elasticsearch.xpack.esql.core.type.DataType.TSID_DATA_TYPE; +import static org.elasticsearch.xpack.esql.core.type.DataType.UNDER_CONSTRUCTION; import static org.hamcrest.Matchers.containsString; import static org.hamcrest.Matchers.equalTo; import static org.hamcrest.Matchers.is; @@ -318,6 +319,9 @@ private void testLookupJoinTypes(String group) { initIndexes(group); initData(group); for (TestConfig config : testConfigurations.get(group).configs.values()) { + if ((isValidDataType(config.mainType()) && isValidDataType(config.lookupType())) == false) { + continue; + } String query = String.format( Locale.ROOT, "FROM index | LOOKUP JOIN %s ON %s | KEEP other", @@ -572,4 +576,8 @@ public void testQuery(String query) { assertion().accept(e); } } + + private boolean isValidDataType(DataType dataType) { + return UNDER_CONSTRUCTION.get(dataType) == null || UNDER_CONSTRUCTION.get(dataType).isEnabled(); + } }