[incubator-celeborn] branch main updated: [CELEBORN-114][REFACTOR] Keep same log code in spark2/spark3 of quota exceed (#1058)

[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 dac2ba6b [CELEBORN-114][REFACTOR] Keep same log code in spark2/spark3 
of quota exceed (#1058)
dac2ba6b is described below

commit dac2ba6b4094dff6e6214179eaff5d5b333c15be
Author: Angerszhuuuu <angers....@gmail.com>
AuthorDate: Fri Dec 9 12:13:01 2022 +0800

    [CELEBORN-114][REFACTOR] Keep same log code in spark2/spark3 of quota 
exceed (#1058)
---
 .../apache/spark/shuffle/celeborn/RssShuffleFallbackPolicyRunner.scala  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/client-spark/spark-2/src/main/scala/org/apache/spark/shuffle/celeborn/RssShuffleFallbackPolicyRunner.scala
 
b/client-spark/spark-2/src/main/scala/org/apache/spark/shuffle/celeborn/RssShuffleFallbackPolicyRunner.scala
index e9101b48..05e90ac1 100644
--- 
a/client-spark/spark-2/src/main/scala/org/apache/spark/shuffle/celeborn/RssShuffleFallbackPolicyRunner.scala
+++ 
b/client-spark/spark-2/src/main/scala/org/apache/spark/shuffle/celeborn/RssShuffleFallbackPolicyRunner.scala
@@ -62,7 +62,7 @@ class RssShuffleFallbackPolicyRunner(conf: CelebornConf) 
extends Logging {
 
     val available = lifecycleManager.checkQuota()
     if (!available) {
-      logWarning(s"Cluster is not alive!")
+      logWarning(s"Quota exceed for current user 
${lifecycleManager.getUserIdentifier}.")
     }
     available
   }