Skip to content

Commit 1e7167b

Browse files
authored
Fix passing pipeline options to external transforms (#36443)
* Fix passing pipeline options to external transforms * Update CHANGES.md * Update CHANGES.md
1 parent 7e8ca06 commit 1e7167b

2 files changed

Lines changed: 2 additions & 1 deletion

File tree

CHANGES.md

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -95,6 +95,7 @@
9595
## Bugfixes
9696

9797
* Fixed X (Java/Python) ([#X](https://github.com/apache/beam/issues/X)).
98+
* Fixed passing of pipeline options to x-lang transforms when called from the Java SDK (Java) ([#36443](https://github.com/apache/beam/issues/36443)).
9899
* PulsarIO has now changed support status from incomplete to experimental. Both read and writes should now minimally
99100
function (un-partitioned topics, without schema support, timestamp ordered messages for read) (Java)
100101
([#36141](https://github.com/apache/beam/issues/36141)).

sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/External.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -274,8 +274,8 @@ public OutputT expand(InputT input) {
274274
.setComponents(originalComponents)
275275
.setTransform(ptransformBuilder.build())
276276
.setNamespace(getNamespace())
277+
.setPipelineOptions(PipelineOptionsTranslation.toProto(p.getOptions()))
277278
.build();
278-
requestBuilder.setPipelineOptions(PipelineOptionsTranslation.toProto(p.getOptions()));
279279

280280
ExpansionApi.ExpansionResponse response =
281281
clientFactory.getExpansionServiceClient(endpoint).expand(request);

0 commit comments

Comments
 (0)