Skip to content
Snippets Groups Projects
Commit c2231763 authored by Patrick Wendell's avatar Patrick Wendell
Browse files

Small style clean-up

parent fab5cee1
No related branches found
No related tags found
No related merge requests found
......@@ -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
}
......
......@@ -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
}
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment