Fix bug.

Marcelo Vanzin · Marcelo Vanzin · commit 34d02b2c05f4 · 2018-01-10T09:08:48.000-08:00
diff --git a/core/src/main/scala/org/apache/spark/status/AppStatusListener.scala b/core/src/main/scala/org/apache/spark/status/AppStatusListener.scala
@@ -437,7 +437,7 @@ private[spark] class AppStatusListener(
       }
       task.errorMessage = errorMessage
       val delta = task.updateMetrics(event.taskMetrics)
-      maybeUpdate(task, now)
+      update(task, now, last = true)
       delta
     }.orNull
 

Original file line number	Diff line number	Diff line change
`@@ -437,7 +437,7 @@ private[spark] class AppStatusListener(`
`437`	`437`	`}`
`438`	`438`	`task.errorMessage = errorMessage`
`439`	`439`	`val delta = task.updateMetrics(event.taskMetrics)`
`440`		`- maybeUpdate(task, now)`
	`440`	`+ update(task, now, last = true)`
`441`	`441`	`delta`
`442`	`442`	`}.orNull`
`443`	`443`