Description
For:
pcol := ...
tmp := beam.CrossLanguage(..., {"foo": pcol}, ...)
out := beam.CrossLanguage(..., {"bar": tmp}, ...)
In the result model pipeline, the second expanded transform's inputs may hold a map from local name to the original PCollection/node ID, even if the first expansion has changed the output IDs.
Looks like a fix is to move the output name remapping after mergeExpandedWithPipeline: https://github.com/apache/beam/blob/928da54e1a95219bfbfa420fbf9c8fb5514fd683/sdks/go/pkg/beam/core/runtime/graphx/translate.go#L160-L163
Attachments
Issue Links
- links to