[
https://issues.apache.org/jira/browse/BEAM-3017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Groh reassigned BEAM-3017:
---------------------------------
Assignee: (was: Thomas Groh)
> 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: Minor
>
> 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
(v7.6.3#76005)
