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

Posted to issues@beam.apache.org by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2018/12/30 20:12:00 UTC

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

     [ https://issues.apache.org/jira/browse/BEAM-6294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Maximilian Michels closed BEAM-6294.
------------------------------------
       Resolution: Fixed
    Fix Version/s: 2.10.0

Closing because the issue is fixed in the linked PR.

> 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
>            Priority: Major
>             Fix For: 2.10.0
>
>          Time Spent: 50m
>  Remaining Estimate: 0h
>
> 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)