[incubator-celeborn] branch main updated: [CELEBORN-328][MPROVEMENT] Too much noisy log when reserve slot failed (#1262)

[zhouky]

This is an automated email from the ASF dual-hosted git repository.

zhouky pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-celeborn.git


The following commit(s) were added to refs/heads/main by this push:
     new 1132cc25 [CELEBORN-328][MPROVEMENT] Too much noisy log when reserve 
slot failed (#1262)
1132cc25 is described below

commit 1132cc25ab1717b67c3fd53b8f0632b3b7d96f71
Author: Angerszhuuuu <angers....@gmail.com>
AuthorDate: Wed Feb 22 17:19:52 2023 +0800

    [CELEBORN-328][MPROVEMENT] Too much noisy log when reserve slot failed 
(#1262)
---
 .../src/main/java/org/apache/celeborn/client/ShuffleClientImpl.java   | 2 +-
 .../src/main/scala/org/apache/celeborn/client/LifecycleManager.scala  | 4 ++--
 2 files changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/client/src/main/java/org/apache/celeborn/client/ShuffleClientImpl.java 
b/client/src/main/java/org/apache/celeborn/client/ShuffleClientImpl.java
index adc604e4..ad95aab6 100644
--- a/client/src/main/java/org/apache/celeborn/client/ShuffleClientImpl.java
+++ b/client/src/main/java/org/apache/celeborn/client/ShuffleClientImpl.java
@@ -379,7 +379,7 @@ public class ShuffleClientImpl extends ShuffleClient {
           }
           return result;
         } else if (StatusCode.SLOT_NOT_AVAILABLE.equals(respStatus)) {
-          logger.warn(
+          logger.error(
               "LifecycleManager request slots return {}, retry again, remain 
retry times {}",
               StatusCode.SLOT_NOT_AVAILABLE,
               numRetries - 1);
diff --git 
a/client/src/main/scala/org/apache/celeborn/client/LifecycleManager.scala 
b/client/src/main/scala/org/apache/celeborn/client/LifecycleManager.scala
index 21b9ac5c..6754d127 100644
--- a/client/src/main/scala/org/apache/celeborn/client/LifecycleManager.scala
+++ b/client/src/main/scala/org/apache/celeborn/client/LifecycleManager.scala
@@ -415,11 +415,11 @@ class LifecycleManager(appId: String, val conf: 
CelebornConf) extends RpcEndpoin
 
     res.status match {
       case StatusCode.REQUEST_FAILED =>
-        logError(s"OfferSlots RPC request failed for $shuffleId!")
+        logDebug(s"OfferSlots RPC request failed for $shuffleId!")
         reply(RegisterShuffleResponse(StatusCode.REQUEST_FAILED, Array.empty))
         return
       case StatusCode.SLOT_NOT_AVAILABLE =>
-        logError(s"OfferSlots for $shuffleId failed!")
+        logDebug(s"OfferSlots for $shuffleId failed!")
         reply(RegisterShuffleResponse(StatusCode.SLOT_NOT_AVAILABLE, 
Array.empty))
         return
       case StatusCode.SUCCESS =>