This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to tag nightly-master
in repository https://gitbox.apache.org/repos/asf/beam.git.
*** WARNING: tag nightly-master was modified! ***
from b0e9f26 (commit)
to cf8e08f (commit)
from b0e9f26 [BEAM-3304] Go triggering support (#15239)
add 2135e5e [BEAM-12780] StreamingDataflowWorker should only retry
exceptions locally for up to 5 minutes
add 8fc27c8 Merge pull request #15360: [BEAM-12780]
StreamingDataflowWorker should only retry exceptions locally for up to 5 minutes
add 2fd9cd1 [BEAM-10917] Add support for BigQuery Read API in Python BEAM
(#15185)
add cc2a07b Change filter to also retry on 408 errors.
add 5563e46 Merge pull request #15367 from ryanthompson591/retry_on_408
add 706e20f [BEAM-9487] Disable allowing unsafe triggers by default
add cf8e08f Merge pull request #15340 from zhoufek/gbk_233
No new revisions were added by this update.
Summary of changes:
CHANGES.md | 6 +-
.../dataflow/worker/StreamingDataflowWorker.java | 13 +
sdks/python/apache_beam/io/gcp/bigquery.py | 344 ++++++++++++++++++++-
.../apache_beam/io/gcp/bigquery_read_it_test.py | 161 +++++++++-
.../python/apache_beam/options/pipeline_options.py | 3 +-
.../runners/dataflow/internal/apiclient.py | 3 +-
sdks/python/apache_beam/transforms/core.py | 29 +-
sdks/python/setup.py | 1 +
8 files changed, 527 insertions(+), 33 deletions(-)