Forward-integrate: merge master into v2
#567
Conversation
Recent PR #491 changes how KafkaIO splits. This makes it incompatible with Dataflow update across these two versions.
* Update version range dependency to exclude 2.0.0-betaX versions * fixup
Increase KafkaIO version to 0.2.0
* Fix HadoopFileSource’s split size estimate * Properly set interrupted state
…-proof * We created a helper in BigQueryIO to create a JobConfigurationQuery capturing all options, but we had not yet propagated this cleanup into the Services abstraction or helper classes. Refactor BigQueryServices and BigQueryTableRowIterator to propagate the same configuration. Adds a new deprecated constructor to BigQueryTableRowIterator for backwards-compatibility. This fixes #539.
Fix InProcessPipelineRunner to handle a null subscription
BigQuery: fix an issue with option propagation and refactor to future-proof
Small fix for BigtableIO's WriteOperation.finalize
Fixed documentation
…ermination This is a backport of BEAM-1880 apache/beam#2428
DataflowPipelineJob: gracefully handle cancellation concurrent with termination
Cache result of BigQuerySourceBase.split
Makes cachedSplitResult transient in BigQuerySourceBase
|
So there's good news and bad news. 👍 The good news is that everyone that needs to sign a CLA (the pull request submitter and all commit authors) have done so. Everything is all good there. 😕 The bad news is that it appears that one or more commits were authored by someone other than the pull request submitter. We need to confirm that they're okay with their commits being contributed to this project. Please have them confirm that here in the pull request. Note to project maintainer: This is a terminal state, meaning the |
|
LGTM, please self-merge on green. |
|
Well, it passed, so I'll merge. |
No description provided.