diff --git a/airbyte-integrations/connectors/destination-bigquery/src/main/java/io/airbyte/integrations/destination/bigquery/writer/BigQueryTableWriter.java b/airbyte-integrations/connectors/destination-bigquery/src/main/java/io/airbyte/integrations/destination/bigquery/writer/BigQueryTableWriter.java index bfd75148093e..2f55e81a7266 100644 --- a/airbyte-integrations/connectors/destination-bigquery/src/main/java/io/airbyte/integrations/destination/bigquery/writer/BigQueryTableWriter.java +++ b/airbyte-integrations/connectors/destination-bigquery/src/main/java/io/airbyte/integrations/destination/bigquery/writer/BigQueryTableWriter.java @@ -51,7 +51,7 @@ public void close(boolean hasFailed) throws IOException { this.writeChannel.close(); try { Job job = writeChannel.getJob(); - while (!JobStatus.State.DONE.equals(writeChannel.getJob().getStatus())) { + while (!JobStatus.State.DONE.equals(job.getStatus())) { Thread.sleep(1000L); job = job.reload(); }