diff --git a/plugin/trino-bigquery/src/main/java/io/trino/plugin/bigquery/BigQueryPageSink.java b/plugin/trino-bigquery/src/main/java/io/trino/plugin/bigquery/BigQueryPageSink.java
index 7a969aad5547..bf378f654eb9 100644
--- a/plugin/trino-bigquery/src/main/java/io/trino/plugin/bigquery/BigQueryPageSink.java
+++ b/plugin/trino-bigquery/src/main/java/io/trino/plugin/bigquery/BigQueryPageSink.java
@@ -119,11 +119,15 @@ private void insertWithCommitted(JSONArray batch)
     @Override
     public CompletableFuture<Collection<Slice>> finish()
     {
+        client.close();
         Slice value = Slices.allocate(Long.BYTES);
         value.setLong(0, pageSinkId.getId());
         return completedFuture(ImmutableList.of(value));
     }
 
     @Override
-    public void abort() {}
+    public void abort()
+    {
+        client.close();
+    }
 }