[beam] branch release-2.30.0 updated: Fixes a case where BigQuery sink swallows HttpErrors preventing retries.

[heejong]

This is an automated email from the ASF dual-hosted git repository.

heejong pushed a commit to branch release-2.30.0
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/release-2.30.0 by this push:
     new 812b61b  Fixes a case where BigQuery sink swallows HttpErrors 
preventing retries.
     new 38b1fa9  Merge pull request #14843 from ihji/cherry-pick-12362
812b61b is described below

commit 812b61bf9e88cdf45cfe74343a922ed448eb35ce
Author: Chamikara Jayalath <chamikar...@gmail.com>
AuthorDate: Tue May 18 15:06:12 2021 -0700

    Fixes a case where BigQuery sink swallows HttpErrors preventing retries.
---
 sdks/python/apache_beam/io/gcp/bigquery_tools.py | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/sdks/python/apache_beam/io/gcp/bigquery_tools.py 
b/sdks/python/apache_beam/io/gcp/bigquery_tools.py
index ad0b830..e1d310d 100644
--- a/sdks/python/apache_beam/io/gcp/bigquery_tools.py
+++ b/sdks/python/apache_beam/io/gcp/bigquery_tools.py
@@ -642,6 +642,9 @@ class BigQueryWrapper(object):
           service_call_metric.call(error.reason)
     except HttpError as e:
       service_call_metric.call(e)
+
+      # Re-reise the exception so that we re-try appropriately.
+      raise
     finally:
       self._latency_histogram_metric.update(
           int(time.time() * 1000) - started_millis)