aboutsummaryrefslogtreecommitdiff
path: root/core
diff options
context:
space:
mode:
authorPatrick Wendell <pwendell@gmail.com>2013-08-13 16:56:37 -0700
committerPatrick Wendell <pwendell@gmail.com>2013-08-13 16:56:37 -0700
commitc2231763885540a2268b45c53ebd06f9baaf06aa (patch)
tree68690c09a54f3a846811acd2936f041679d1f9f5 /core
parentfab5cee111767a7edbbdc9020f4c1d456b264184 (diff)
downloadspark-c2231763885540a2268b45c53ebd06f9baaf06aa.tar.gz
spark-c2231763885540a2268b45c53ebd06f9baaf06aa.tar.bz2
spark-c2231763885540a2268b45c53ebd06f9baaf06aa.zip
Small style clean-up
Diffstat (limited to 'core')
-rw-r--r--core/src/main/scala/spark/executor/Executor.scala2
-rw-r--r--core/src/main/scala/spark/scheduler/local/LocalScheduler.scala2
2 files changed, 2 insertions, 2 deletions
diff --git a/core/src/main/scala/spark/executor/Executor.scala b/core/src/main/scala/spark/executor/Executor.scala
index 6bfb132023..c5202d94b0 100644
--- a/core/src/main/scala/spark/executor/Executor.scala
+++ b/core/src/main/scala/spark/executor/Executor.scala
@@ -158,7 +158,7 @@ private[spark] class Executor(executorId: String, slaveHostname: String, propert
case t: Throwable => {
val serviceTime = (System.currentTimeMillis() - taskStart).toInt
val metrics = attemptedTask.flatMap(t => t.metrics)
- metrics.foreach{m =>
+ metrics.foreach {m =>
m.executorRunTime = serviceTime
m.jvmGCTime = getTotalGCTime - startGCTime
}
diff --git a/core/src/main/scala/spark/scheduler/local/LocalScheduler.scala b/core/src/main/scala/spark/scheduler/local/LocalScheduler.scala
index 322c32543f..33e7a10ea4 100644
--- a/core/src/main/scala/spark/scheduler/local/LocalScheduler.scala
+++ b/core/src/main/scala/spark/scheduler/local/LocalScheduler.scala
@@ -218,7 +218,7 @@ private[spark] class LocalScheduler(threads: Int, val maxFailures: Int, val sc:
case t: Throwable => {
val serviceTime = System.currentTimeMillis() - taskStart
val metrics = attemptedTask.flatMap(t => t.metrics)
- metrics.foreach{ m =>
+ metrics.foreach {m =>
m.executorRunTime = serviceTime.toInt
m.jvmGCTime = getTotalGCTime - startGCTime
}