Ben Chambers questions

Ben Chambers answers

• Google Cloud Dataflow: Accessing Google Cloud Pub/Sub in pipeline with DirectPipelineRunner (local job)?
• Is it possible to update google dataflow job with a new pipeline?
• google dataflow: the type Sum.SumIntegerFn is not visible
• Avro: Reusing a decoder
• Load data stored on google cloud storage with multi character delimiter to BigQuery
• Using CoGroupByKey with custom type ends up in a Coder error
• Google dataflow, DATA_LOSS Exception
• Dataflow concurrency error with ValueState
• Google Dataflow "Workflow failed" with no reason
• Error: Message: Too many sources provided: 15285. Limit is 10000