Skip to content

Commit 4455616

Browse files
authored
feat(io-gcp-bigquery): Add log for direct read quota exceeded retries (#36717)
When a BigQuery direct read operation exceeds its quota, it returns a `RESOURCE_EXHAUSTED` error with retry information. The system correctly handles this by retrying the operation after a delay. This commit adds an informational log message to make this specific retry event more visible. This helps in diagnosing performance issues or understanding why a job might be experiencing delays, as it explicitly indicates that retries are occurring due to quota limitations.
1 parent ca57641 commit 4455616

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryServicesImpl.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1838,6 +1838,7 @@ public void onRetryAttempt(Status status, Metadata metadata) {
18381838
&& status.getCode() == Code.RESOURCE_EXHAUSTED
18391839
&& metadata != null
18401840
&& metadata.containsKey(KEY_RETRY_INFO)) {
1841+
LOG.info("BigQuery direct read quota exceeded, retrying.");
18411842
RetryInfo retryInfo = metadata.get(KEY_RETRY_INFO);
18421843
if (retryInfo.hasRetryDelay()) {
18431844
long delay =

0 commit comments

Comments
 (0)