Github user kanzhang commented on a diff in the pull request:
https://github.com/apache/spark/pull/306#discussion_r11235230
--- Diff: core/src/main/scala/org/apache/spark/deploy/master/Master.scala
---
@@ -290,10 +290,11 @@ private[spark] class Master(
appInfo.removeExecutor(exec)
exec.worker.removeExecutor(exec)
+ val normalExit = exitStatus.exists(_ == 0)
--- End diff --
My line 370 is " addressToWorker.get(address).foreach(removeWorker)".
I'm not sure this is what you meant.
> the current implementation set the Executor status to KILLED no matter it
is exists normally or is due to the ctrl+c
the current implementation sets Executor status to FAILED when it exits
normally and that's what I wanted to correct here, by introducing EXITED
status, which could mean either normal or abnormal exit.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
