This is an automated email from the ASF dual-hosted git repository. angerszhuuuu pushed a commit to branch branch-0.2 in repository https://gitbox.apache.org/repos/asf/incubator-celeborn.git
commit 82d2db506989cb042c519f6633b334e05ceb6d72 Author: Angerszhuuuu <[email protected]> AuthorDate: Wed Dec 14 18:25:18 2022 +0800 [CELEBORN-141][IMPROVEMENT] Refactor error log about quota exceed (#1086) --- common/src/main/scala/org/apache/celeborn/common/quota/Quota.scala | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/common/src/main/scala/org/apache/celeborn/common/quota/Quota.scala b/common/src/main/scala/org/apache/celeborn/common/quota/Quota.scala index d9aa5883..d2280f8d 100644 --- a/common/src/main/scala/org/apache/celeborn/common/quota/Quota.scala +++ b/common/src/main/scala/org/apache/celeborn/common/quota/Quota.scala @@ -52,7 +52,7 @@ case class Quota( val exceed = (diskBytesWritten > 0 && value >= diskBytesWritten) if (exceed) { logWarning(s"User $userIdentifier quota exceed diskBytesWritten, " + - s"$value >= $diskBytesWritten") + s"${Utils.bytesToString(value)} >= ${Utils.bytesToString(diskBytesWritten)}") } exceed } @@ -69,7 +69,7 @@ case class Quota( val exceed = (hdfsBytesWritten > 0 && value >= hdfsBytesWritten) if (exceed) { logWarning(s"User $userIdentifier quota exceed hdfsBytesWritten, " + - s"$value >= $hdfsBytesWritten") + s"${Utils.bytesToString(value)} >= ${Utils.bytesToString(hdfsBytesWritten)}") } exceed }
