diff options
| author | Karen Feng <karenfeng.us@gmail.com> | 2013-07-24 13:43:09 -0700 |
|---|---|---|
| committer | Karen Feng <karenfeng.us@gmail.com> | 2013-07-24 13:43:09 -0700 |
| commit | 57009eef9099aa3b35b9262d9637af3dc94266a1 (patch) | |
| tree | 6895329f9f8fc19fe7d5aaa0bf1e5a709506a8b0 /core | |
| parent | 4280e1768d09e43b55f26556e14a8eb70d9b9fad (diff) | |
| download | spark-57009eef9099aa3b35b9262d9637af3dc94266a1.tar.gz spark-57009eef9099aa3b35b9262d9637af3dc94266a1.tar.bz2 spark-57009eef9099aa3b35b9262d9637af3dc94266a1.zip | |
Fixed consistency of "success" status string
Diffstat (limited to 'core')
| -rw-r--r-- | core/src/main/scala/spark/ui/jobs/StagePage.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/core/src/main/scala/spark/ui/jobs/StagePage.scala b/core/src/main/scala/spark/ui/jobs/StagePage.scala index b77b29045e..654f347723 100644 --- a/core/src/main/scala/spark/ui/jobs/StagePage.scala +++ b/core/src/main/scala/spark/ui/jobs/StagePage.scala @@ -61,7 +61,7 @@ private[spark] class StagePage(parent: JobProgressUI) { val taskTable = listingTable(taskHeaders, taskRow, tasks) // Excludes tasks which failed and have incomplete metrics - val validTasks = tasks.filter(t => t._1.status == "SUCCESSFUL" && (Option(t._2).isDefined)) + val validTasks = tasks.filter(t => t._1.status == "SUCCESS" && (Option(t._2).isDefined)) val summaryTable: Option[Seq[Node]] = if (validTasks.size == 0) { |