GoogleCloudPlatform/DataflowJavaSDK
Google Cloud Dataflow provides a simple, powerful model for building both batch and streaming parallel data processing pipelines.
Issues
- 6
- 9
Since porting to 2.1.0, Dataflow is leaving Datasets/Tables behind in BigQuery
#609 opened by polleyg - 11
BigQueryIO need underlying "bigquery.tables.get permission" access to query a view
#557 opened by wli600 - 0
- 0
Running a jar file from cloud function
#583 opened by kpr6 - 3
Cloud Dataflow Template
#579 opened by kpr6 - 5
Caused by: java.io.NotSerializableException: com.beam.example.config.ElasticsearchRestClientConfig
#651 opened by nithinsridhar - 4
java.lang.IllegalStateException: Value only available at runtime, but accessed from a non-runtime context: RuntimeValueProvider
#650 opened by davidscottturner - 2
- 2
PCollection<Void> instead of PDone
#645 opened by brucedeen - 4
Cannot launch template with repeated parameters
#632 opened by dadrian - 5
Take 2: Error when reading from External Unbounded Source and Write to PubSubIO
#589 opened by cbazza - 5
Dataflow discarding massive amount of events due to Window object or inner processing
#648 opened by turboT4 - 1
- 0
Repo incorrectly deleted
#646 opened by elharo - 1
- 1
- 3
Dataflow combine globally default coder
#630 opened by lboudard - 1
- 19
Google API Client Library version 1.23.0 causes runtime problems with Dataflow Java SDK
#607 opened by moandcompany - 4
- 1
Dataflow /var/opt/google/dataflow directory created as /var/opt/google/dataflow/dataflow
#636 opened by junying1 - 4
Cannot set region for BigQuery dataset when using direct runner using Apache Beam
#635 opened by doduythao - 0
- 1
How to pass command line args in Eclipse DF Plugin
#631 opened by SMukherjee4 - 3
Cannot stage dataflow job (java.net.SocketTimeoutException & java.io.IOException)
#625 opened by mastronaute - 0
- 4
TextIO.writeCustomType cannot be used with DynamicDestinations.getDestination
#619 opened by janhicken - 1
Conversion of PCollection<TableSchema> to TableSchema object
#580 opened by kpr6 - 1
Since porting to 2.1.0, pipeline now fails when it encounters an empty `PCollection` for BigQuery sink/output
#610 opened by polleyg - 0
Researching Build Breakage
#615 opened by clanghout - 0
- 1
RAND_RANGE in WindowedWordCount is not used
#612 opened by elharo - 0
Dependency conflicts
#611 opened by elharo - 1
- 6
- 1
- 0
Decompressing bzip2 files with multiple "streams" only reads the first stream leading to data loss
#596 opened by lukecwik - 1
- 0
DataflowPathValidator.verifyPathIsAccessible should throw checked exception, not runtime exception
#586 opened by elharo - 1
Unable to use google dataflow JAVA SDK 1.8 version with google-cloud-pubsub version 0.20.0-beta
#584 opened by seehans - 0
InvocationTargetException: Filepattern cannot be empty.
#582 opened by kpr6 - 3
- 6
- 0
Add Java 7 maven enforcement to Dataflow pom.xml
#572 opened by dhalperi - 4
- 2
- 1
TextIO - add "allow empty" flag
#556 opened by rantibi - 2
Using Service Account with dataflow
#554 opened by seehans - 1
Need a Sink/Source for Spanner
#552 opened by guymolinari