Edit spilling log from MB to B

shenh062326 · shenh062326 · commit 946351ce11f9 · 2014-11-13T20:38:09.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
@@ -105,7 +105,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 MB to disk (%d time%s so far)"
-        .format(threadId, size / (1024 * 1024), _spillCount, if (_spillCount > 1) "s" else ""))
+    logInfo("Thread %d spilling in-memory map of %d B to disk (%d time%s so far)"
+        .format(threadId, size, _spillCount, if (_spillCount > 1) "s" else ""))
   }
 }

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