This is an automated email from the ASF dual-hosted git repository.
reuvenlax pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from c843883 Merge pull request #6103: [BEAM-4793] Enable schemas for
Dataflow runner.
add 1dc4f7f Fix BigQuery job retry mechanism.
add a0d4f4b Add exponential backoff on retries.
add cfa254b Apply code-review comment.
add 6cb6e94 Properly handle running jobs.
new 57084e8 Merge pull request #6080: [BEAM-5040] Fix retry bug for
BigQuery jobs.
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../beam/sdk/io/gcp/bigquery/BatchLoads.java | 32 +++++--
.../beam/sdk/io/gcp/bigquery/BigQueryHelpers.java | 100 +++++++++++++++++++++
.../beam/sdk/io/gcp/bigquery/BigQueryIO.java | 5 ++
.../beam/sdk/io/gcp/bigquery/BigQueryServices.java | 2 +-
.../sdk/io/gcp/bigquery/BigQueryServicesImpl.java | 10 ++-
.../beam/sdk/io/gcp/bigquery/WriteRename.java | 84 ++++++++++++++---
.../beam/sdk/io/gcp/bigquery/WriteTables.java | 93 +++++++++++++++----
.../sdk/io/gcp/bigquery/BigQueryIOWriteTest.java | 7 +-
.../beam/sdk/io/gcp/bigquery/FakeJobService.java | 31 ++++++-
9 files changed, 318 insertions(+), 46 deletions(-)
