Skip to content
Snippets Groups Projects
Commit 6a31b719 authored by Matei Zaharia's avatar Matei Zaharia
Browse files

Small bug fix

parent 2f1736c3
No related branches found
No related tags found
No related merge requests found
......@@ -130,7 +130,7 @@ private[spark] class ExecutorsUI(val sc: SparkContext) {
val eid = taskEnd.taskInfo.executorId
if (!executorToTasksActive.contains(eid))
executorToTasksActive(eid) = HashSet[Long]()
executorToTasksActive(eid) -= taskStart.taskInfo.taskId
executorToTasksActive(eid) -= taskEnd.taskInfo.taskId
val (failureInfo, metrics): (Option[ExceptionFailure], Option[TaskMetrics]) =
taskEnd.reason match {
case e: ExceptionFailure =>
......@@ -146,4 +146,4 @@ private[spark] class ExecutorsUI(val sc: SparkContext) {
executorToTaskInfos(eid) = taskList
}
}
}
\ No newline at end of file
}
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