Properly use close after push

airbytehq · Oct 2, 2023 · 0cfe7a1 · 0cfe7a1
1 parent 0fb85bf
commit 0cfe7a1
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/.../java/io/airbyte/integrations/destination/bigquery/uploader/AbstractBigQueryUploader.java b/.../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);
     }