Fix job refresh

airbytehq · Oct 11, 2023 · 006094d · 006094d
1 parent 850db67
commit 006094d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...rc/main/java/io/airbyte/integrations/destination/bigquery/writer/BigQueryTableWriter.java b/...rc/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();
       }