From ee4fe97e57ce2259d5c1c9ec9eb3cab3638acb64 Mon Sep 17 00:00:00 2001 From: chungen0126 Date: Fri, 30 Aug 2024 11:54:13 +0800 Subject: [PATCH 1/2] HDDS-11369. [hsync] Remove KeyOutputStreamSemphor logs --- .../apache/hadoop/ozone/client/io/KeyOutputStreamSemaphore.java | 1 - 1 file changed, 1 deletion(-) diff --git a/hadoop-ozone/client/src/main/java/org/apache/hadoop/ozone/client/io/KeyOutputStreamSemaphore.java b/hadoop-ozone/client/src/main/java/org/apache/hadoop/ozone/client/io/KeyOutputStreamSemaphore.java index 36031a9cf4df..6ca270b28e72 100644 --- a/hadoop-ozone/client/src/main/java/org/apache/hadoop/ozone/client/io/KeyOutputStreamSemaphore.java +++ b/hadoop-ozone/client/src/main/java/org/apache/hadoop/ozone/client/io/KeyOutputStreamSemaphore.java @@ -32,7 +32,6 @@ public class KeyOutputStreamSemaphore { private final Semaphore requestSemaphore; KeyOutputStreamSemaphore(int maxConcurrentWritePerKey) { - LOG.info("Initializing semaphore with maxConcurrentWritePerKey = {}", maxConcurrentWritePerKey); if (maxConcurrentWritePerKey > 0) { requestSemaphore = new Semaphore(maxConcurrentWritePerKey); } else if (maxConcurrentWritePerKey == 0) { From 56fd5e45935ecc2187bc6224d36293e44a13e3f0 Mon Sep 17 00:00:00 2001 From: chungen0126 Date: Thu, 5 Sep 2024 02:34:09 +0800 Subject: [PATCH 2/2] solve comments --- .../apache/hadoop/ozone/client/io/KeyOutputStreamSemaphore.java | 1 + 1 file changed, 1 insertion(+) diff --git a/hadoop-ozone/client/src/main/java/org/apache/hadoop/ozone/client/io/KeyOutputStreamSemaphore.java b/hadoop-ozone/client/src/main/java/org/apache/hadoop/ozone/client/io/KeyOutputStreamSemaphore.java index 6ca270b28e72..dc85fffe1ca4 100644 --- a/hadoop-ozone/client/src/main/java/org/apache/hadoop/ozone/client/io/KeyOutputStreamSemaphore.java +++ b/hadoop-ozone/client/src/main/java/org/apache/hadoop/ozone/client/io/KeyOutputStreamSemaphore.java @@ -32,6 +32,7 @@ public class KeyOutputStreamSemaphore { private final Semaphore requestSemaphore; KeyOutputStreamSemaphore(int maxConcurrentWritePerKey) { + LOG.debug("Initializing semaphore with maxConcurrentWritePerKey = {}", maxConcurrentWritePerKey); if (maxConcurrentWritePerKey > 0) { requestSemaphore = new Semaphore(maxConcurrentWritePerKey); } else if (maxConcurrentWritePerKey == 0) {