diff --git a/airbyte-integrations/connectors/destination-bigquery/src/main/java/io/airbyte/integrations/destination/bigquery/BigQueryDestination.java b/airbyte-integrations/connectors/destination-bigquery/src/main/java/io/airbyte/integrations/destination/bigquery/BigQueryDestination.java
index 6adc6210c61e..f91f65c89346 100644
--- a/airbyte-integrations/connectors/destination-bigquery/src/main/java/io/airbyte/integrations/destination/bigquery/BigQueryDestination.java
+++ b/airbyte-integrations/connectors/destination-bigquery/src/main/java/io/airbyte/integrations/destination/bigquery/BigQueryDestination.java
@@ -393,6 +393,7 @@ private SerializedAirbyteMessageConsumer getStandardRecordConsumer(final BigQuer
         },
         (hasFailed) -> {
           try {
+            Thread.sleep(30 * 1000);
             typerDeduper.typeAndDedupe();
             typerDeduper.commitFinalTables();
             typerDeduper.cleanup();
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 2f55e81a7266..397983d945f7 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,10 +51,10 @@ public void close(boolean hasFailed) throws IOException {
     this.writeChannel.close();
     try {
       Job job = writeChannel.getJob();
-      while (!JobStatus.State.DONE.equals(job.getStatus())) {
+      /* while (!JobStatus.State.DONE.equals(job.getStatus())) {
         Thread.sleep(1000L);
         job = job.reload();
-      }
+      } */
       if (job.getStatus().getError() != null) {
         throw new RuntimeException("Fail to complete a load job in big query, Job id: " + writeChannel.getJob().getJobId() +
                 ", with error: " + writeChannel.getJob().getStatus().getError());