[ https://issues.apache.org/jira/browse/BEAM-1311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15837060#comment-15837060 ]
Thomas Groh commented on BEAM-1311: ----------------------------------- Basically I munged a call to {{getTag()}} and a call to {{getInputs()}} in https://github.com/apache/beam/pull/1735; The fix is in https://github.com/apache/beam/pull/1839 > Flink Translations are not properly 1-to-1 with the PValues, PInputs, or > POutputs > --------------------------------------------------------------------------------- > > Key: BEAM-1311 > URL: https://issues.apache.org/jira/browse/BEAM-1311 > Project: Beam > Issue Type: Bug > Components: runner-flink > Reporter: Thomas Groh > Assignee: Thomas Groh > Priority: Critical > > Flatten is broken in streaming, and ParDo.BoundMulti is broken in batch. This > has broken all Flink Pipelines in those contexts. -- This message was sent by Atlassian JIRA (v6.3.4#6332)