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()) {