Bug fix: SPARK-789

https://spark-project.atlassian.net/browse/SPARK-789
2013-07-05 00:54:10 +08:00 · 2013-07-05 00:54:10 +08:00 · c0c3155c3c
parent 6d60fe571a
commit c0c3155c3c
1 changed files with 3 additions and 1 deletions
--- a/core/src/main/scala/spark/deploy/master/Master.scala
+++ b/core/src/main/scala/spark/deploy/master/Master.scala
@ -278,7 +278,9 @@ private[spark] class Master(host: String, port: Int, webUiPort: Int) extends Act
        exec.state = ExecutorState.KILLED
      }
      app.markFinished(state)
-      app.driver ! ApplicationRemoved(state.toString)
+      if (state != ApplicationState.FINISHED) {
+        app.driver ! ApplicationRemoved(state.toString)
+      }
      schedule()
    }
  }