(beam) branch fix-sqlbigquery updated: Catch exception

[vterentev]

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

vterentev pushed a commit to branch fix-sqlbigquery
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/fix-sqlbigquery by this push:
     new 0fe256ff305 Catch exception
0fe256ff305 is described below

commit 0fe256ff3050ef30b86aa2d523829f64b16f59e2
Author: Vitaly Terentyev <vitaly.terent...@akvelon.com>
AuthorDate: Fri Jul 11 19:36:36 2025 +0400

    Catch exception
---
 .../runners/dataflow/worker/windmill/client/grpc/GrpcGetDataStream.java | 2 ++
 1 file changed, 2 insertions(+)

diff --git 
a/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/client/grpc/GrpcGetDataStream.java
 
b/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/client/grpc/GrpcGetDataStream.java
index 7de074122a3..13ef9cc7c79 100644
--- 
a/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/client/grpc/GrpcGetDataStream.java
+++ 
b/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/client/grpc/GrpcGetDataStream.java
@@ -424,6 +424,8 @@ final class GrpcGetDataStream
           BackOffUtils.next(Sleeper.DEFAULT, backoff);
         } catch (InterruptedException ie) {
           Thread.currentThread().interrupt();
+        } catch (Exception exc) {
+          throw new RuntimeException(exc);
         }
       } catch (InterruptedException e) {
         Thread.currentThread().interrupt();