Skip to content
This repository was archived by the owner on Mar 23, 2026. It is now read-only.

Commit 7d05e0a

Browse files
authored
Merge branch 'main' into kirl/jdbc
2 parents b361cee + 2578dcb commit 7d05e0a

2 files changed

Lines changed: 10 additions & 2 deletions

File tree

google-cloud-bigquery/src/main/java/com/google/cloud/bigquery/ConnectionImpl.java

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1069,7 +1069,15 @@ private void processArrowStreamAsync(
10691069
}
10701070

10711071
} catch (Exception e) {
1072-
throw BigQueryException.translateAndThrow(e);
1072+
if (e instanceof InterruptedException || e.getCause() instanceof InterruptedException) {
1073+
// Log silently and let it fall through to 'finally' for cleanup.
1074+
// This is the "graceful shutdown".
1075+
logger.log(
1076+
Level.INFO, "Background thread interrupted (Connection Closed). Stopping.");
1077+
Thread.currentThread().interrupt();
1078+
} else {
1079+
throw BigQueryException.translateAndThrow(e);
1080+
}
10731081
} finally { // logic needed for graceful shutdown
10741082
// marking end of stream
10751083
try {

samples/snippets/pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -47,7 +47,7 @@
4747
<dependency>
4848
<groupId>com.google.cloud</groupId>
4949
<artifactId>libraries-bom</artifactId>
50-
<version>26.64.0</version>
50+
<version>26.73.0</version>
5151
<type>pom</type>
5252
<scope>import</scope>
5353
</dependency>

0 commit comments

Comments
 (0)