Repository: flink Updated Branches: refs/heads/master 201f55b85 -> cd7ed8e38
[FLINK-2206] [webui] Fix incorrect counts of finished, canceled, and failed jobs in new web dashboard This closes #1287 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/4db27060 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/4db27060 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/4db27060 Branch: refs/heads/master Commit: 4db27060b3ebaf13e3e03ac4864c3b43ac776bb6 Parents: 201f55b Author: Fabian Hueske <fhue...@apache.org> Authored: Thu Oct 22 14:41:11 2015 +0200 Committer: Fabian Hueske <fhue...@apache.org> Committed: Thu Oct 22 20:51:14 2015 +0200 ---------------------------------------------------------------------- .../flink/runtime/jobmanager/MemoryArchivist.scala | 16 +--------------- 1 file changed, 1 insertion(+), 15 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/4db27060/flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/MemoryArchivist.scala ---------------------------------------------------------------------- diff --git a/flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/MemoryArchivist.scala b/flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/MemoryArchivist.scala index bef52e0..2d55b26 100644 --- a/flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/MemoryArchivist.scala +++ b/flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/MemoryArchivist.scala @@ -188,21 +188,7 @@ class MemoryArchivist(private val max_entries: Int) // -------------------------------------------------------------------------- private def createJobsOverview() : JobsOverview = { - var runningOrPending = 0 - var finished = 0 - var canceled = 0 - var failed = 0 - - graphs.values.foreach { - _.getState() match { - case JobStatus.FINISHED => finished += 1 - case JobStatus.CANCELED => canceled += 1 - case JobStatus.FAILED => failed += 1 - case _ => runningOrPending += 1 - } - } - - new JobsOverview(runningOrPending, finished, canceled, failed) + new JobsOverview(0, finishedCnt, canceledCnt, failedCnt) } private def createJobsWithIDsOverview() : JobsWithIDsOverview = {
