This closes #1506

apache · Dec 6, 2016 · 9d380de · 9d380de
2 parents 8a1fb21 + f3edaeb
commit 9d380de
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/...o/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIO.java b/...o/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIO.java
@@ -2140,15 +2140,16 @@ private void load(
               .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",