[ https://issues.apache.org/jira/browse/BEAM-6294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Thomas Weise reopened BEAM-6294: -------------------------------- Reopening the issue since it breaks our application: * The PR contains substantial changes but no test coverage * It isn't clear from looking at this ticket how this change relates to the existing PTransformTranslation.RESHUFFLE_URN translation (our streaming pipeline is also using reshuffle) Can we revert this in master and 2.10 release branch until there is an opportunity to fully solve it? > 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)