[
https://issues.apache.org/jira/browse/BEAM-7421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16848851#comment-16848851
]
Maximilian Michels commented on BEAM-7421:
------------------------------------------
Thanks, good catch!
> 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
> Priority: Major
>
> 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)
