beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From da...@apache.org
Subject [1/2] incubator-beam git commit: Improve BigQuery load error message
Date Tue, 06 Dec 2016 20:24:18 GMT
Repository: incubator-beam
Updated Branches:
  refs/heads/master 8a1fb2164 -> 9d380de96


Improve BigQuery load error message


Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/f3edaeb4
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/f3edaeb4
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/f3edaeb4

Branch: refs/heads/master
Commit: f3edaeb4f07c66d5ef48afdf16ebd2226f67cefa
Parents: 8a1fb21
Author: Sam McVeety <sgmc@google.com>
Authored: Sun Dec 4 14:28:39 2016 -0800
Committer: Davor Bonaci <davor@google.com>
Committed: Tue Dec 6 12:24:07 2016 -0800

----------------------------------------------------------------------
 .../java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIO.java  | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/f3edaeb4/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIO.java
----------------------------------------------------------------------
diff --git a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIO.java
b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIO.java
index 0e01246..c00c19d 100644
--- a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIO.java
+++ b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIO.java
@@ -2140,15 +2140,16 @@ public class BigQueryIO {
               .setProjectId(projectId)
               .setJobId(jobId);
           jobService.startLoadJob(jobRef, loadConfig);
-          Status jobStatus =
-              parseStatus(jobService.pollJob(jobRef, Bound.LOAD_JOB_POLL_MAX_RETRIES));
+          Job job = jobService.pollJob(jobRef, Bound.LOAD_JOB_POLL_MAX_RETRIES);
+          Status jobStatus = parseStatus(job);
           switch (jobStatus) {
             case SUCCEEDED:
               return;
             case UNKNOWN:
               throw new RuntimeException("Failed to poll the load job status of job " + jobId);
             case FAILED:
-              LOG.info("BigQuery load job failed: {}", jobId);
+              LOG.info("BigQuery load job failed. Status: {} Details: {}",
+                  jobId, job.getStatus());
               continue;
             default:
               throw new IllegalStateException(String.format("Unexpected job status: %s of
job %s",


Mime
View raw message