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 d9aa5883b..d2280f8df 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 }