From b00ef056d6aff004938275a7ff5981c3be2b4e26 Mon Sep 17 00:00:00 2001 From: Yi Hu Date: Thu, 21 May 2026 11:30:56 -0400 Subject: [PATCH 1/2] Suppress log spams in gcsio 3.0 --- .../apache/beam/sdk/extensions/gcp/util/GcsUtilV1.java | 10 ++++++++++ 1 file changed, 10 insertions(+) diff --git a/sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/util/GcsUtilV1.java b/sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/util/GcsUtilV1.java index 97778ac4e1df..e8e1ec70e4fe 100644 --- a/sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/util/GcsUtilV1.java +++ b/sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/util/GcsUtilV1.java @@ -71,6 +71,7 @@ import java.util.concurrent.LinkedBlockingQueue; import java.util.concurrent.ThreadPoolExecutor; import java.util.concurrent.TimeUnit; +import java.util.concurrent.atomic.AtomicBoolean; import java.util.concurrent.atomic.AtomicInteger; import java.util.function.Consumer; import java.util.function.Supplier; @@ -184,6 +185,7 @@ public boolean shouldRetry(IOException e) { return RetryDeterminer.SOCKET_ERRORS.shouldRetry(e); } }; + private static final AtomicBoolean overwriteLog = new AtomicBoolean(false); ///////////////////////////////////////////////////////////////////////////// @@ -729,6 +731,14 @@ public WritableByteChannel create(GcsPath path, CreateOptions options) throws IO GoogleCloudStorage createGoogleCloudStorage( GoogleCloudStorageOptions options, Storage storage, Credentials credentials) throws IOException { + // Suppress log spams in gcsio 3.0 + if (overwriteLog.compareAndSet(false, true)) { + java.util.logging.Logger gcsLogger = + java.util.logging.Logger.getLogger( + "com.google.cloud.hadoop.gcsio.GoogleCloudStorageImpl"); + gcsLogger.setLevel(java.util.logging.Level.SEVERE); + } + return GoogleCloudStorageImpl.builder() .setOptions(options) .setHttpTransport(storage.getRequestFactory().getTransport()) From 3de3e90b553ab1d3c6e5caa8ebd0f24796112a13 Mon Sep 17 00:00:00 2001 From: Yi Hu Date: Thu, 21 May 2026 18:40:32 -0400 Subject: [PATCH 2/2] Suppress spotbug finding static reference exist in GoogleCloudStorageImpl --- .../org/apache/beam/sdk/extensions/gcp/util/GcsUtilV1.java | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) diff --git a/sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/util/GcsUtilV1.java b/sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/util/GcsUtilV1.java index e8e1ec70e4fe..1ad08f0ba1a2 100644 --- a/sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/util/GcsUtilV1.java +++ b/sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/util/GcsUtilV1.java @@ -728,15 +728,14 @@ public WritableByteChannel create(GcsPath path, CreateOptions options) throws IO } } + @SuppressFBWarnings("LG_LOST_LOGGER_DUE_TO_WEAK_REFERENCE") GoogleCloudStorage createGoogleCloudStorage( GoogleCloudStorageOptions options, Storage storage, Credentials credentials) throws IOException { // Suppress log spams in gcsio 3.0 if (overwriteLog.compareAndSet(false, true)) { - java.util.logging.Logger gcsLogger = - java.util.logging.Logger.getLogger( - "com.google.cloud.hadoop.gcsio.GoogleCloudStorageImpl"); - gcsLogger.setLevel(java.util.logging.Level.SEVERE); + java.util.logging.Logger.getLogger("com.google.cloud.hadoop.gcsio.GoogleCloudStorageImpl") + .setLevel(java.util.logging.Level.SEVERE); } return GoogleCloudStorageImpl.builder()