Edit spilling log from MB to B

shenh062326 · shenh062326 · commit e9145e8ac679 · 2014-11-14T09:14:45.000+08:00
diff --git a/core/src/main/scala/org/apache/spark/util/collection/Spillable.scala b/core/src/main/scala/org/apache/spark/util/collection/Spillable.scala
@@ -106,7 +106,7 @@ private[spark] trait Spillable[C] {
    */
   @inline private def logSpillage(size: Long) {
     val threadId = Thread.currentThread().getId
-    logInfo("Thread %d spilling in-memory map of %d B to disk (%d time%s so far)"
+    logInfo("Thread %d spilling in-memory map of %s to disk (%d time%s so far)"
         .format(threadId, Utils.bytesToString(size), _spillCount, if (_spillCount > 1) "s" else ""))
   }
 }

Original file line number	Diff line number	Diff line change
`@@ -106,7 +106,7 @@ private[spark] trait Spillable[C] {`
`106`	`106`	`*/`
`107`	`107`	`@inline private def logSpillage(size: Long) {`
`108`	`108`	`val threadId = Thread.currentThread().getId`
`109`		`- logInfo("Thread %d spilling in-memory map of %d B to disk (%d time%s so far)"`
	`109`	`+ logInfo("Thread %d spilling in-memory map of %s to disk (%d time%s so far)"`
`110`	`110`	`.format(threadId, Utils.bytesToString(size), _spillCount, if (_spillCount > 1) "s" else ""))`
`111`	`111`	`}`
`112`	`112`	`}`