diff options
| author | Matei Zaharia <matei@eecs.berkeley.edu> | 2013-07-23 16:20:24 -0700 |
|---|---|---|
| committer | Matei Zaharia <matei@eecs.berkeley.edu> | 2013-07-23 16:20:24 -0700 |
| commit | 6a31b7191d5a8203563a2a4e600210c67439abf5 (patch) | |
| tree | 7fd3ce028fd9677087b7614a735a98200c366625 /core | |
| parent | 2f1736c3967b5ae20710cc52e84b3e4a7c041a0b (diff) | |
| download | spark-6a31b7191d5a8203563a2a4e600210c67439abf5.tar.gz spark-6a31b7191d5a8203563a2a4e600210c67439abf5.tar.bz2 spark-6a31b7191d5a8203563a2a4e600210c67439abf5.zip | |
Small bug fix
Diffstat (limited to 'core')
| -rw-r--r-- | core/src/main/scala/spark/ui/exec/ExecutorsUI.scala | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/core/src/main/scala/spark/ui/exec/ExecutorsUI.scala b/core/src/main/scala/spark/ui/exec/ExecutorsUI.scala index 69fb306074..bad5c442ab 100644 --- a/core/src/main/scala/spark/ui/exec/ExecutorsUI.scala +++ b/core/src/main/scala/spark/ui/exec/ExecutorsUI.scala @@ -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 +} |