-
- Downloads
Remove erroneous FAILED state for killed tasks.
Currently, when tasks are killed, the Executor first sends a status update for the task with a "KILLED" state, and then sends a second status update with a "FAILED" state saying that the task failed due to an exception. The second FAILED state is misleading/unncessary, and occurs due to a NonLocalReturnControl Exception that gets thrown due to the way we kill tasks. This commit eliminates that problem.
Showing
- core/src/main/scala/org/apache/spark/executor/Executor.scala 13 additions, 11 deletionscore/src/main/scala/org/apache/spark/executor/Executor.scala
- core/src/main/scala/org/apache/spark/scheduler/TaskSchedulerImpl.scala 2 additions, 1 deletion.../scala/org/apache/spark/scheduler/TaskSchedulerImpl.scala
Loading
Please register or sign in to comment