Skip to content

Commit

Permalink
Edit spilling log from MB to B
Browse files Browse the repository at this point in the history
  • Loading branch information
shenh062326 committed Nov 14, 2014
1 parent 946351c commit da761c2
Showing 1 changed file with 2 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -19,6 +19,7 @@ package org.apache.spark.util.collection

import org.apache.spark.Logging
import org.apache.spark.SparkEnv
import org.apache.spark.util.Utils

/**
* Spills contents of an in-memory collection to disk when the memory threshold
Expand Down Expand Up @@ -106,6 +107,6 @@ 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)"
.format(threadId, size, _spillCount, if (_spillCount > 1) "s" else ""))
.format(threadId, Utils.bytesToString(size), _spillCount, if (_spillCount > 1) "s" else ""))
}
}

0 comments on commit da761c2

Please sign in to comment.