From 8261c79c7bfb04c08a6a621af7632d5d17a879fe Mon Sep 17 00:00:00 2001 From: Danny McCormick Date: Wed, 8 Oct 2025 15:25:45 -0400 Subject: [PATCH 1/3] Fix passing pipeline options to external transforms --- .../java/org/apache/beam/sdk/util/construction/External.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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); From 2831608adae0305fe0e15eae72bab0d4ef6b4fba Mon Sep 17 00:00:00 2001 From: Danny McCormick Date: Wed, 8 Oct 2025 15:28:03 -0400 Subject: [PATCH 2/3] Update CHANGES.md --- CHANGES.md | 1 + 1 file changed, 1 insertion(+) diff --git a/CHANGES.md b/CHANGES.md index a7406c1f88ac..36645229ac39 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/pull/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)). From a1fd5ee215bed5ee94d3d90580c4dd0954304d91 Mon Sep 17 00:00:00 2001 From: Danny McCormick Date: Wed, 8 Oct 2025 15:52:34 -0400 Subject: [PATCH 3/3] Update CHANGES.md --- CHANGES.md | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/CHANGES.md b/CHANGES.md index 36645229ac39..6a8f0bbd41d1 100644 --- a/CHANGES.md +++ b/CHANGES.md @@ -95,7 +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/pull/36443)). +* 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)).