diff --git a/airbyte-integrations/connectors/destination-bigquery/src/main/java/io/airbyte/integrations/destination/bigquery/uploader/AbstractBigQueryUploader.java b/airbyte-integrations/connectors/destination-bigquery/src/main/java/io/airbyte/integrations/destination/bigquery/uploader/AbstractBigQueryUploader.java
index 23ef53fbc16e..0c3a91a436f2 100644
--- a/airbyte-integrations/connectors/destination-bigquery/src/main/java/io/airbyte/integrations/destination/bigquery/uploader/AbstractBigQueryUploader.java
+++ b/airbyte-integrations/connectors/destination-bigquery/src/main/java/io/airbyte/integrations/destination/bigquery/uploader/AbstractBigQueryUploader.java
@@ -111,7 +111,7 @@ public void close(final boolean hasFailed, final Consumer<AirbyteMessage> output
 
   public void closeAfterPush() {
     try {
-      this.writer.close(false);
+      this.writer.closeAfterPush();
     } catch (IOException e) {
       throw new RuntimeException(e);
     }