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 60ae698475d3..1bf3491746cc 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
@@ -396,12 +396,12 @@ private SerializedAirbyteMessageConsumer getStandardRecordConsumer(final BigQuer
             });
           }
         },
-        () -> {
+        (hasFailed) -> {
           LOGGER.info("Started closing all connections");
           final List<Exception> exceptionsThrown = new ArrayList<>();
           writeConfigs.get().forEach((streamId, uploader) -> {
             try {
-              uploader.close(false, outputRecordCollector, null);
+              uploader.close(hasFailed, outputRecordCollector, null);
             } catch (final Exception e) {
               exceptionsThrown.add(e);
               LOGGER.error("Exception while closing uploader {}", uploader, e);