Mike Kaplinskiy created BEAM-7421:
-------------------------------------
Summary: Flink/Spark non-portable runners doesn't override
Reshuffle
Key: BEAM-7421
URL: https://issues.apache.org/jira/browse/BEAM-7421
Project: Beam
Issue Type: Bug
Components: runner-flink, runner-spark
Reporter: Mike Kaplinskiy
Both the flink and the spark runners attempt to override the {{Reshuffle}}
transform via the urn - e.g.
[https://github.com/apache/beam/blob/master/runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkBatchTransformTranslators.java#L114]
.
Unfortunately there's no {{TransformPayloadTranslatorRegistrar}} for
{{Reshuffle}}. This means the call to {{urnForTransformOrNull}} will always
return {{null}} for a {{Reshuffle}} so they are never translated.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
