Repository: flink Updated Branches: refs/heads/release-0.10 e340f839a -> c72eff4af
[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/dadb1a80 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/dadb1a80 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/dadb1a80 Branch: refs/heads/release-0.10 Commit: dadb1a8030d8d2e1bd5e6826c1c9632d3d6ddf8b Parents: e340f83 Author: Fabian Hueske <fhue...@apache.org> Authored: Thu Oct 22 14:41:11 2015 +0200 Committer: Fabian Hueske <fhue...@apache.org> Committed: Fri Oct 23 10:09:10 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/dadb1a80/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 = {
