[CELEBORN-141][IMPROVEMENT] Refactor error log about quota exceed (#1086)
This commit is contained in:
parent
ed26356cf7
commit
83c85fc351
@ -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
|
||||
}
|
||||
|
||||
Loading…
Reference in New Issue
Block a user