[
https://issues.apache.org/jira/browse/BEAM-4826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16570945#comment-16570945
]
Luke Cwik commented on BEAM-4826:
-
This seems like a case where the GreedyPipelineFuser is incorrectly
[
https://issues.apache.org/jira/browse/BEAM-4826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16566235#comment-16566235
]
Henning Rohde commented on BEAM-4826:
-
Dataflow drops the flatten altogether.
> Flink runner sends
[
https://issues.apache.org/jira/browse/BEAM-4826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16566224#comment-16566224
]
Ankur Goenka commented on BEAM-4826:
[~herohde] Quick question.
What do you mean by "Dataflow removes
[
https://issues.apache.org/jira/browse/BEAM-4826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16566219#comment-16566219
]
Henning Rohde commented on BEAM-4826:
-
Yeah - unused outputs from ParDo is fine. As you say, they may
[
https://issues.apache.org/jira/browse/BEAM-4826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16565838#comment-16565838
]
Ankur Goenka commented on BEAM-4826:
I see.
The split of flatten is ok. I will see how we can
