Fix condition

airbytehq · Oct 11, 2023 · 850db67 · 850db67
1 parent aa431a7
commit 850db67
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 2 deletions.
diff --git a/...query/src/main/java/io/airbyte/integrations/destination/bigquery/BigQueryDestination.java b/...query/src/main/java/io/airbyte/integrations/destination/bigquery/BigQueryDestination.java
@@ -393,7 +393,6 @@ private SerializedAirbyteMessageConsumer getStandardRecordConsumer(final BigQuer
         },
         (hasFailed) -> {
           try {
-            Thread.sleep(30 * 1000);
             typerDeduper.typeAndDedupe();
             typerDeduper.commitFinalTables();
             typerDeduper.cleanup();

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(writeChannel.getJob().getStatus())) {
         Thread.sleep(1000L);
         job = job.reload();
       }