[
https://issues.apache.org/jira/browse/BEAM-2007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17132425#comment-17132425
]
Beam JIRA Bot commented on BEAM-2007:
-------------------------------------
This issue is assigned but has not received an update in 30 days so it has been
labeled "stale-assigned". If you are still working on the issue, please give an
update and remove the label. If you are no longer working on the issue, please
unassign so someone else may work on it. In 7 days the issue will be
automatically unassigned.
> DataflowRunner drops Reads with no consumers
> --------------------------------------------
>
> Key: BEAM-2007
> URL: https://issues.apache.org/jira/browse/BEAM-2007
> Project: Beam
> Issue Type: Bug
> Components: runner-dataflow, sdk-py-core
> Reporter: Dan Halperin
> Assignee: Ahmet Altay
> Priority: P2
> Labels: stale-assigned
>
> Basically, if a pipeline has "just" a Read with no consumers, the optimizer
> in Dataflow will drop it. To preserve Beam semantics, we do want to run the
> Read and drop its output, e.g., because the Read may have side effects that
> we're testing for.
> Is it possible with pipeline surgery to find such Reads and add an Identity
> ParDo to them?
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
