[jira] [Updated] (BEAM-8608) Chain DoFns in Flink batch runner when possible.

2019-11-14 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/BEAM-8608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-8608: - Status: Open (was: Triage Needed) > Chain DoFns in Flink batch runner when possible. >

[jira] [Updated] (BEAM-8608) Chain DoFns in Flink batch runner when possible.

2019-11-11 Thread David Moravek (Jira)
[ https://issues.apache.org/jira/browse/BEAM-8608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Moravek updated BEAM-8608: Description: Right now, in Batch runner, DoFn is executed using MapPartition operator

[jira] [Updated] (BEAM-8608) Chain DoFns in Flink batch runner when possible.

2019-11-11 Thread David Moravek (Jira)
[ https://issues.apache.org/jira/browse/BEAM-8608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Moravek updated BEAM-8608: Attachment: Screen Shot 2019-11-07 at 10.35.22.png > Chain DoFns in Flink batch runner when

[jira] [Updated] (BEAM-8608) Chain DoFns in Flink batch runner when possible.

2019-11-11 Thread David Moravek (Jira)
[ https://issues.apache.org/jira/browse/BEAM-8608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Moravek updated BEAM-8608: Attachment: Screen Shot 2019-11-07 at 10.35.07.png > Chain DoFns in Flink batch runner when