You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@beam.apache.org by "Robert Bradshaw (JIRA)" <ji...@apache.org> on 2018/12/21 16:43:00 UTC

[jira] [Created] (BEAM-6294) Use Flink's redistribute for reshuffle.

Robert Bradshaw created BEAM-6294:
-------------------------------------

             Summary: Use Flink's redistribute for reshuffle.
                 Key: BEAM-6294
                 URL: https://issues.apache.org/jira/browse/BEAM-6294
             Project: Beam
          Issue Type: New Feature
          Components: runner-flink, sdk-py-core
            Reporter: Robert Bradshaw
            Assignee: Robert Bradshaw


Python needs to publish the URN over the FnAPI which is pretty easy, but Flink also needs to ensure that the composite structure does not get fused. Unlike with GBK, we can't assume all runners implement this as a primitive. 



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)