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 e9145e8 commit 21ee960
Showing 1 changed file with 1 addition and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,6 @@ 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 @@ -107,6 +106,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 %s to disk (%d time%s so far)"
.format(threadId, 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 21ee960

Please sign in to comment.