claudevdm commented on code in PR #38015:
URL: https://github.com/apache/beam/pull/38015#discussion_r3017314040
##########
sdks/python/apache_beam/io/gcp/bigquery_change_history.py:
##########
@@ -838,16 +911,19 @@ def process(
_utc(element.range_end),
table_key)
+ # Release the storage client so the gRPC channel doesn't go stale
+ # between process() calls. _ensure_client() will create a fresh one.
+ self._storage_client = None
Review Comment:
There has been issues where the connection hangs forever if the client is
open for long enough. Might consider a TTL or something but will leave like
this for now.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
