diff options
| author | Patrick Wendell <pwendell@gmail.com> | 2013-01-28 21:48:32 -0800 |
|---|---|---|
| committer | Patrick Wendell <pwendell@gmail.com> | 2013-01-28 21:48:32 -0800 |
| commit | 7ee824e42ebaa1fc0b0248e0a35021108625ed14 (patch) | |
| tree | 45b311c93ce1f627d418bd8a9934a8b12bbe5a79 | |
| parent | 501433f1d59b1b326c0a7169fa1fd6136f7628e3 (diff) | |
| download | spark-7ee824e42ebaa1fc0b0248e0a35021108625ed14.tar.gz spark-7ee824e42ebaa1fc0b0248e0a35021108625ed14.tar.bz2 spark-7ee824e42ebaa1fc0b0248e0a35021108625ed14.zip | |
Units from ms -> s
| -rw-r--r-- | core/src/main/scala/spark/scheduler/DAGScheduler.scala | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/core/src/main/scala/spark/scheduler/DAGScheduler.scala b/core/src/main/scala/spark/scheduler/DAGScheduler.scala index 7ba1f3430a..b8336d9d06 100644 --- a/core/src/main/scala/spark/scheduler/DAGScheduler.scala +++ b/core/src/main/scala/spark/scheduler/DAGScheduler.scala @@ -413,10 +413,10 @@ class DAGScheduler(taskSched: TaskScheduler) extends TaskSchedulerListener with def markStageAsFinished(stage: Stage) = { val serviceTime = stage.submissionTime match { - case Some(t) => (System.currentTimeMillis() - t).toString + case Some(t) => "%.03f".format((System.currentTimeMillis() - t) / 1000.0) case _ => "Unkown" } - logInfo("%s (%s) finished in %s ms".format(stage, stage.origin, serviceTime)) + logInfo("%s (%s) finished in %s s".format(stage, stage.origin, serviceTime)) running -= stage } event.reason match { |