aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorDavies Liu <davies.liu@gmail.com>2016-02-05 22:40:40 -0800
committerDavies Liu <davies.liu@gmail.com>2016-02-05 22:40:40 -0800
commit4f28291f851b9062da3941e63de4eabb0c77f5d0 (patch)
tree1202146ee60dceecf485dbb1ae8ae481a046eef1
parent6883a5120c6b3a806024dfad03b8bf7371c6c0eb (diff)
downloadspark-4f28291f851b9062da3941e63de4eabb0c77f5d0.tar.gz
spark-4f28291f851b9062da3941e63de4eabb0c77f5d0.tar.bz2
spark-4f28291f851b9062da3941e63de4eabb0c77f5d0.zip
[HOTFIX] fix float part of avgRate
-rw-r--r--core/src/main/scala/org/apache/spark/util/Benchmark.scala2
1 files changed, 1 insertions, 1 deletions
diff --git a/core/src/main/scala/org/apache/spark/util/Benchmark.scala b/core/src/main/scala/org/apache/spark/util/Benchmark.scala
index d1699f5c28..1bf6f821e9 100644
--- a/core/src/main/scala/org/apache/spark/util/Benchmark.scala
+++ b/core/src/main/scala/org/apache/spark/util/Benchmark.scala
@@ -124,7 +124,7 @@ private[spark] object Benchmark {
}
val best = runTimes.min
val avg = runTimes.sum / iters
- Result(avg / 1000000, num / (best / 1000), best / 1000000)
+ Result(avg / 1000000.0, num / (best / 1000.0), best / 1000000.0)
}
}