diff --git a/CHANGES.md b/CHANGES.md index a7406c1f88ac..6a8f0bbd41d1 100644 --- a/CHANGES.md +++ b/CHANGES.md @@ -95,6 +95,7 @@ ## Bugfixes * Fixed X (Java/Python) ([#X](https://github.com/apache/beam/issues/X)). +* Fixed passing of pipeline options to x-lang transforms when called from the Java SDK (Java) ([#36443](https://github.com/apache/beam/issues/36443)). * PulsarIO has now changed support status from incomplete to experimental. Both read and writes should now minimally function (un-partitioned topics, without schema support, timestamp ordered messages for read) (Java) ([#36141](https://github.com/apache/beam/issues/36141)). diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/External.java b/sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/External.java index 3ff97e2726e7..6204ae445f8c 100644 --- a/sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/External.java +++ b/sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/External.java @@ -274,8 +274,8 @@ public OutputT expand(InputT input) { .setComponents(originalComponents) .setTransform(ptransformBuilder.build()) .setNamespace(getNamespace()) + .setPipelineOptions(PipelineOptionsTranslation.toProto(p.getOptions())) .build(); - requestBuilder.setPipelineOptions(PipelineOptionsTranslation.toProto(p.getOptions())); ExpansionApi.ExpansionResponse response = clientFactory.getExpansionServiceClient(endpoint).expand(request);