ODIn/spark-instrumented-optimizer
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

Utils.memoryBytesToString fixed

Browse source
This commit is contained in:
Richard Benkovsky 2012-05-19 15:13:20 +02:00
parent 10716b1766
commit 822a4be37d
1 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
core/src/main/scala/spark/Utils.scala
View file

@ -2,11 +2,11 @@ package spark
import java.io._
import java.net.InetAddress
import java.util.UUID
import java.util.concurrent.{Executors, ThreadFactory, ThreadPoolExecutor}
import scala.collection.mutable.ArrayBuffer
import scala.util.Random
import java.util.{Locale, UUID}
/**
* Various utility methods used by Spark.
@ -184,7 +184,7 @@ object Utils {
val GB = 1L << 30
val MB = 1L << 20
val KB = 1L << 10
val B = 1L
val (value, unit) = {
if (size >= 2*GB) {
(size.asInstanceOf[Double] / GB, "GB")
@ -196,6 +196,6 @@ object Utils {
(size.asInstanceOf[Double], "B")
}
}
"%.1f%s".format(value, unit)
"%.1f%s".formatLocal(Locale.US, value, unit)
}
}