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:59 UTC

[beam] 01/01: Merge pull request #6080: [BEAM-5040] Fix retry bug for BigQuery jobs.

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(-)