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

Commit 9e21b4e

Browse files
committed
chore: address gemini feedback
1 parent 3f357c2 commit 9e21b4e

1 file changed

Lines changed: 3 additions & 8 deletions

File tree

google-cloud-bigquery-jdbc/src/main/java/com/google/cloud/bigquery/jdbc/BigQueryStatement.java

Lines changed: 3 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -844,7 +844,7 @@ Thread populateArrowBufferedQueue(
844844
} catch (com.google.api.gax.rpc.ApiException e) {
845845
if (e.getStatusCode().getCode()
846846
== com.google.api.gax.rpc.StatusCode.Code.NOT_FOUND) {
847-
LOG.warning("Read session expired or not found" + ": %s", e.getMessage());
847+
LOG.warning("Read session expired or not found: %s", e.getMessage());
848848
break;
849849
}
850850
long elapsedSecs = (System.currentTimeMillis() - startTime) / 1000;
@@ -864,13 +864,8 @@ Thread populateArrowBufferedQueue(
864864
try {
865865
Thread.sleep(this.connection.getRetryInitialDelayInSeconds() * 1000);
866866
} catch (InterruptedException ie) {
867-
LOG.log(
868-
Level.WARNING,
869-
"\n"
870-
+ Thread.currentThread().getName()
871-
+ " Interrupted @ arrowStreamProcessor waiting for retry",
872-
ie);
873-
break;
867+
Thread.currentThread().interrupt();
868+
throw new BigQueryJdbcRuntimeException(ie);
874869
}
875870
}
876871
}

0 commit comments

Comments
 (0)