[jira] [Updated] (BEAM-3017) DropInputs on BigQueryIO.writeTableRows() sink

[ https://issues.apache.org/jira/browse/BEAM-3017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mingwei Samuel updated BEAM-3017: - Description: After upgrade to version 2.1.0 there are "DropInput##" transforms on every output of

[jira] [Created] (BEAM-3017) DropInputs on every Sink, Breaking Transform Flow

Mingwei Samuel created BEAM-3017: Summary: DropInputs on every Sink, Breaking Transform Flow Key: BEAM-3017 URL: https://issues.apache.org/jira/browse/BEAM-3017 Project: Beam Issue Type: Bug

[jira] [Commented] (BEAM-991) DatastoreIO Write should flush early for large batches

[ https://issues.apache.org/jira/browse/BEAM-991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16178079#comment-16178079 ] Mingwei Samuel commented on BEAM-991: - Is this fixed? The patches are in 2.1.0 release, right? >

[jira] [Commented] (BEAM-991) DatastoreIO Write should flush early for large batches

[ https://issues.apache.org/jira/browse/BEAM-991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16057102#comment-16057102 ] Mingwei Samuel commented on BEAM-991: - Also want to chime in that I'm hitting this issue. Found it via