[MINOR] Adjust log level for PushDataHandler#checkDiskFullAndSplit …

…from debug to trace ### What changes were proposed in this pull request? As title ### Why are the changes needed? This PR modifies the log level from debug to trace for the `PushDataHandler#checkDiskFullAndSplit` method, which is invoked with each `PushData` request. This change is aimed at addressing the issue of excessive log volume caused by the high frequency of `PushData` requests. ### Does this PR introduce _any_ user-facing change? No ### How was this patch tested? Pass GA Closes apache#2007 from cfmcgrady/check-disk-full-and-split-log-level. Authored-by: Fu Chen <cfmcgrady@gmail.com> Signed-off-by: mingji <fengmingxiao.fmx@alibaba-inc.com>
wilsonjie · Oct 20, 2023 · 5b6e197 · 5b6e197
1 parent f778324
commit 5b6e197
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/worker/src/main/scala/org/apache/celeborn/service/deploy/worker/PushDataHandler.scala b/worker/src/main/scala/org/apache/celeborn/service/deploy/worker/PushDataHandler.scala
@@ -1209,11 +1209,11 @@ class PushDataHandler extends BaseMessageHandler with Logging {
       softSplit: AtomicBoolean,
       callback: RpcResponseCallback): Boolean = {
     val diskFull = checkDiskFull(fileWriter)
-    logDebug(
+    logTrace(
       s"""
          |CheckDiskFullAndSplit in
          |diskFull:$diskFull,
-         |partitionSplitMinimumSize: $partitionSplitMinimumSize,
+         |partitionSplitMinimumSize:$partitionSplitMinimumSize,
          |splitThreshold:${fileWriter.getSplitThreshold()},
          |fileLength:${fileWriter.getFileInfo.getFileLength}
          |fileName:${fileWriter.getFileInfo.getFilePath}
@@ -1225,7 +1225,7 @@ class PushDataHandler extends BaseMessageHandler with Logging {
         softSplit.set(true)
       } else {
         callback.onSuccess(ByteBuffer.wrap(Array[Byte](StatusCode.HARD_SPLIT.getValue)))
-        logDebug(
+        logTrace(
           s"""
              |CheckDiskFullAndSplit hardSplit
              |diskFull:$diskFull,