This is an automated email from the ASF dual-hosted git repository. ethanfeng pushed a commit to branch branch-0.2 in repository https://gitbox.apache.org/repos/asf/incubator-celeborn.git
commit 68cdc201454610bc41e9569b4812d81d81e96fe5 Author: Angerszhuuuu <[email protected]> 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 }
