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 21ee960 commit 4653378
Showing 1 changed file with 2 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -106,6 +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 %s to disk (%d time%s so far)"
.format(threadId, org.apache.spark.util.Utils.bytesToString(size), _spillCount, if (_spillCount > 1) "s" else ""))
.format(threadId, org.apache.spark.util.Utils.bytesToString(size),
_spillCount, if (_spillCount > 1) "s" else ""))
}
}

0 comments on commit 4653378

Please sign in to comment.