diff --git a/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/transform/transforms/TransformConfig.java b/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/transform/transforms/TransformConfig.java index fd9e6c64fade1..f13e72dcd22c5 100644 --- a/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/transform/transforms/TransformConfig.java +++ b/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/transform/transforms/TransformConfig.java @@ -387,13 +387,6 @@ ActionRequestValidationException validateNoCrossProjectWhenCrossProjectFeatureIs validationException ); } - // verify there is no project routing - if (getSource().getProjectRouting() != null) { - validationException = addValidationError( - "Cross-project calls are not supported, but project_routing was requested: " + getSource().getProjectRouting(), - validationException - ); - } } return validationException; } diff --git a/x-pack/plugin/core/src/test/java/org/elasticsearch/xpack/core/transform/transforms/TransformConfigTests.java b/x-pack/plugin/core/src/test/java/org/elasticsearch/xpack/core/transform/transforms/TransformConfigTests.java index 28dcca4e3927a..1523e18f51476 100644 --- a/x-pack/plugin/core/src/test/java/org/elasticsearch/xpack/core/transform/transforms/TransformConfigTests.java +++ b/x-pack/plugin/core/src/test/java/org/elasticsearch/xpack/core/transform/transforms/TransformConfigTests.java @@ -1139,10 +1139,6 @@ public void testCrossProjectWithFeatureDisabled() throws IOException { validationException.getMessage(), containsString("Cross-project calls are not supported, but remote indices were requested: [project-1:src]") ); - assertThat( - validationException.getMessage(), - containsString("Cross-project calls are not supported, but project_routing was requested: _alias:_origin") - ); } public void testNotCrossProjectEnvironment() throws IOException { diff --git a/x-pack/plugin/transform/src/main/java/org/elasticsearch/xpack/transform/action/TransportValidateTransformAction.java b/x-pack/plugin/transform/src/main/java/org/elasticsearch/xpack/transform/action/TransportValidateTransformAction.java index 7a4fb8239c88b..9ca1c7ff68dbe 100644 --- a/x-pack/plugin/transform/src/main/java/org/elasticsearch/xpack/transform/action/TransportValidateTransformAction.java +++ b/x-pack/plugin/transform/src/main/java/org/elasticsearch/xpack/transform/action/TransportValidateTransformAction.java @@ -33,7 +33,6 @@ import org.elasticsearch.xpack.core.transform.action.ValidateTransformAction; import org.elasticsearch.xpack.core.transform.action.ValidateTransformAction.Request; import org.elasticsearch.xpack.core.transform.action.ValidateTransformAction.Response; -import org.elasticsearch.xpack.core.transform.transforms.TransformConfig; import org.elasticsearch.xpack.transform.TransformServices; import org.elasticsearch.xpack.transform.transforms.FunctionFactory; import org.elasticsearch.xpack.transform.transforms.TransformNodes; @@ -152,8 +151,7 @@ protected void doExecute(Task task, Request request, ActionListener li // <3> Validate Project Routing is not set when CPS is not supported ActionListener validateProjectRoutingListener = validateConfigListener.delegateFailureAndWrap((l, ignored) -> { - if (config.getSource().getProjectRouting() == null - || (crossProjectModeDecider.crossProjectEnabled() && TransformConfig.TRANSFORM_CROSS_PROJECT.isEnabled())) { + if (config.getSource().getProjectRouting() == null || crossProjectModeDecider.crossProjectEnabled()) { l.onResponse(true); } else { l.onFailure(