diff --git a/google-cloud-bigquery/src/main/java/com/google/cloud/bigquery/BigQueryImpl.java b/google-cloud-bigquery/src/main/java/com/google/cloud/bigquery/BigQueryImpl.java index 25ea72af4563..c4d6f0f7ae88 100644 --- a/google-cloud-bigquery/src/main/java/com/google/cloud/bigquery/BigQueryImpl.java +++ b/google-cloud-bigquery/src/main/java/com/google/cloud/bigquery/BigQueryImpl.java @@ -234,11 +234,16 @@ public com.google.api.services.bigquery.model.Job call() { // and get might work. // We can only do this if we randomly generated the ID. Otherwise we might mistakenly // fetch a job created by someone else. + Job job; try { - return getJob(jobInfo.getJobId()); + job = getJob(jobInfo.getJobId()); } catch (BigQueryException e) { throw createException; } + if (job == null) { + throw createException; + } + return job; } @Override