You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by re...@apache.org on 2018/07/31 17:57:58 UTC
[beam] branch master updated (c843883 -> 57084e8)
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(-)
[beam] 01/01: Merge pull request #6080: [BEAM-5040] Fix retry bug
for BigQuery jobs.
Posted by re...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
reuvenlax pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
commit 57084e89fe296ad274a54ed18bb59a909b41a5a1
Merge: c843883 6cb6e94
Author: reuvenlax <re...@google.com>
AuthorDate: Tue Jul 31 10:57:54 2018 -0700
Merge pull request #6080: [BEAM-5040] Fix retry bug for BigQuery jobs.
.../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(-)