[
https://issues.apache.org/jira/browse/BEAM-3017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17546660#comment-17546660
]
Kenneth Knowles commented on BEAM-3017:
---------------------------------------
This issue has been migrated to https://github.com/apache/beam/issues/18506
> DropInputs on BigQueryIO.writeTableRows() sink
> ----------------------------------------------
>
> Key: BEAM-3017
> URL: https://issues.apache.org/jira/browse/BEAM-3017
> Project: Beam
> Issue Type: Bug
> Components: runner-dataflow
> Affects Versions: 2.1.0
> Reporter: Mingwei Samuel
> Priority: P3
>
> After upgrade to version 2.1.0 there are "DropInput##" transforms on every
> output of my pipeline, outside of their corresponding transforms. They're
> getting added to my
> {{BigQueryIO.<T>writeTableRows()}}
> sinks, even though looking at the source code it appears that these
> "DropInput" transforms are supposed to pull from reads that do not have any
> outputs, so I'm not sure why they're getting added to sinks.
> These transforms are flooding my graph and filling it with junk, for example:
> !https://i.imgur.com/jXtn9Gr.png|thumbnail!
--
This message was sent by Atlassian Jira
(v8.20.7#820007)
