Do not retrieve Blob metadata on batch delete

trinodb · Oct 2, 2024 · f7a25a1 · f7a25a1
1 parent 30cffd1
commit f7a25a1
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/lib/trino-filesystem-gcs/src/main/java/io/trino/filesystem/gcs/GcsFileSystem.java b/lib/trino-filesystem-gcs/src/main/java/io/trino/filesystem/gcs/GcsFileSystem.java
@@ -169,8 +169,8 @@ public void deleteFiles(Collection<Location> locations)
             for (List<Location> locationBatch : partition(locations, batchSize)) {
                 StorageBatch batch = storage.batch();
                 for (Location location : locationBatch) {
-                    getBlob(storage, new GcsLocation(location))
-                            .ifPresent(blob -> batch.delete(blob.getBlobId()));
+                    GcsLocation gcsLocation = new GcsLocation(location);
+                    batch.delete(BlobId.of(gcsLocation.bucket(), gcsLocation.path()));
                 }
                 batchFutures.add(executorService.submit(batch::submit));
             }