You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by da...@apache.org on 2023/03/30 13:02:40 UTC
[beam] branch master updated: BigQueryHelpers: log statuses using PrettyString (#26037)
This is an automated email from the ASF dual-hosted git repository.
damccorm pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/master by this push:
new 40382c84130 BigQueryHelpers: log statuses using PrettyString (#26037)
40382c84130 is described below
commit 40382c84130d9c072c9008913de835fe0f8e72e7
Author: Udi Meiri <ud...@users.noreply.github.com>
AuthorDate: Thu Mar 30 06:02:28 2023 -0700
BigQueryHelpers: log statuses using PrettyString (#26037)
---
.../org/apache/beam/sdk/io/gcp/bigquery/BigQueryHelpers.java | 12 ++++++------
1 file changed, 6 insertions(+), 6 deletions(-)
diff --git a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryHelpers.java b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryHelpers.java
index 362afb008ea..fd7347c45f1 100644
--- a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryHelpers.java
+++ b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryHelpers.java
@@ -244,26 +244,26 @@ public class BigQueryHelpers {
// This might happen if BigQuery's job listing is slow. Retry with the same
// job id.
LOG.info(
- "Load job {} finished in unknown state: {}: {}",
+ "Load job {} finished in unknown state, {}: {}",
currentJobId,
- job.getStatus(),
- shouldRetry() ? "will retry" : "will not retry");
+ shouldRetry() ? "will retry" : "will not retry",
+ statusToPrettyString(job.getStatus()));
return false;
case FAILED:
String oldJobId = currentJobId.getJobId();
- currentJobId = BigQueryHelpers.getRetryJobId(currentJobId, lookupJob).jobId;
+ currentJobId = getRetryJobId(currentJobId, lookupJob).jobId;
LOG.warn(
"Load job {} failed, {}: {}. Next job id {}",
oldJobId,
shouldRetry() ? "will retry" : "will not retry",
- job.getStatus(),
+ statusToPrettyString(job.getStatus()),
currentJobId);
return false;
default:
throw new IllegalStateException(
String.format(
"Unexpected status [%s] of load job: %s.",
- job.getStatus(), BigQueryHelpers.jobToPrettyString(job)));
+ job.getStatus(), jobToPrettyString(job)));
}
}
return false;