From 289ef4051ecf8c22591f3058a2c0f79435903795 Mon Sep 17 00:00:00 2001 From: itsankit-google Date: Wed, 16 Jul 2025 17:57:22 +0000 Subject: [PATCH] Remove log if bucket does not exist --- .../java/io/cdap/plugin/gcp/bigquery/util/BigQueryUtil.java | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/src/main/java/io/cdap/plugin/gcp/bigquery/util/BigQueryUtil.java b/src/main/java/io/cdap/plugin/gcp/bigquery/util/BigQueryUtil.java index be2b88ba0..32ebd149d 100644 --- a/src/main/java/io/cdap/plugin/gcp/bigquery/util/BigQueryUtil.java +++ b/src/main/java/io/cdap/plugin/gcp/bigquery/util/BigQueryUtil.java @@ -720,7 +720,11 @@ public static void deleteTemporaryDirectory(Configuration configuration, String /** * Deletes the GCS bucket. */ - public static void deleteGcsBucket(Storage storage, String bucket) { + public static void deleteGcsBucket(Storage storage, @Nullable String bucket) { + if (Strings.isNullOrEmpty(bucket) || storage.get(bucket) == null) { + return; + } + Page blobs = storage.list(bucket, Storage.BlobListOption.versions(true)); List blobIds = new ArrayList<>(); for (Blob blob : blobs.iterateAll()) {