From 0cfe7a1f572270903d2d6cced3ef029f3a822f7c Mon Sep 17 00:00:00 2001
From: benmoriceau <benoit@airbyte.io>
Date: Mon, 2 Oct 2023 14:43:09 -0700
Subject: [PATCH] Properly use close after push

---
 .../destination/bigquery/uploader/AbstractBigQueryUploader.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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);
     }