Skip to content

Commit fbb1150

Browse files
committed
[SPARK-2714] DAGScheduler logs jobid when runJob finishes
1 parent 7aec2a9 commit fbb1150

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -428,11 +428,11 @@ class DAGScheduler(
428428
val waiter = submitJob(rdd, func, partitions, callSite, allowLocal, resultHandler, properties)
429429
waiter.awaitResult() match {
430430
case JobSucceeded => {
431-
logInfo("Job %d finished: %s, took %ds".format
431+
logInfo("Job %d finished: %s, took %d s".format
432432
(waiter.jobId, callSite.shortForm, (System.nanoTime - start) / 1e9))
433433
}
434434
case JobFailed(exception: Exception) =>
435-
logInfo("Job %d failed: %s, took %ds".format
435+
logInfo("Job %d failed: %s, took %d s".format
436436
(waiter.jobId, callSite.shortForm, (System.nanoTime - start) / 1e9))
437437
throw exception
438438
}

0 commit comments

Comments
 (0)