diff options
author | Patrick Wendell <pwendell@gmail.com> | 2013-08-13 16:56:37 -0700 |
---|---|---|
committer | Patrick Wendell <pwendell@gmail.com> | 2013-08-13 16:56:37 -0700 |
commit | c2231763885540a2268b45c53ebd06f9baaf06aa (patch) | |
tree | 68690c09a54f3a846811acd2936f041679d1f9f5 /core | |
parent | fab5cee111767a7edbbdc9020f4c1d456b264184 (diff) | |
download | spark-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.scala | 2 | ||||
-rw-r--r-- | core/src/main/scala/spark/scheduler/local/LocalScheduler.scala | 2 |
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 } |