Skip to content

Commit 21ee960

Browse files
committed
Edit spilling log from MB to B
1 parent e9145e8 commit 21ee960

File tree

1 file changed

+1
-2
lines changed

1 file changed

+1
-2
lines changed

core/src/main/scala/org/apache/spark/util/collection/Spillable.scala

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,6 @@ package org.apache.spark.util.collection
1919

2020
import org.apache.spark.Logging
2121
import org.apache.spark.SparkEnv
22-
import org.apache.spark.util.Utils
2322

2423
/**
2524
* Spills contents of an in-memory collection to disk when the memory threshold
@@ -107,6 +106,6 @@ private[spark] trait Spillable[C] {
107106
@inline private def logSpillage(size: Long) {
108107
val threadId = Thread.currentThread().getId
109108
logInfo("Thread %d spilling in-memory map of %s to disk (%d time%s so far)"
110-
.format(threadId, Utils.bytesToString(size), _spillCount, if (_spillCount > 1) "s" else ""))
109+
.format(threadId, org.apache.spark.util.Utils.bytesToString(size), _spillCount, if (_spillCount > 1) "s" else ""))
111110
}
112111
}

0 commit comments

Comments
 (0)