diff --git a/core/src/main/scala/spark/scheduler/DAGScheduler.scala b/core/src/main/scala/spark/scheduler/DAGScheduler.scala
index 7ba1f3430a15a1076381d476a57810f897288f4c..b8336d9d0620c02d13c3edf075b662b71a82ce4a 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 {