From 0cac19721f8a7bed34492ad6172fd177f13204fa Mon Sep 17 00:00:00 2001 From: Shixiong Zhu Date: Wed, 17 May 2017 11:07:30 -0700 Subject: [PATCH] Mark task finished --- core/src/main/scala/org/apache/spark/executor/Executor.scala | 1 + 1 file changed, 1 insertion(+) diff --git a/core/src/main/scala/org/apache/spark/executor/Executor.scala b/core/src/main/scala/org/apache/spark/executor/Executor.scala index 3bc47b670305b..5b396687dd11a 100644 --- a/core/src/main/scala/org/apache/spark/executor/Executor.scala +++ b/core/src/main/scala/org/apache/spark/executor/Executor.scala @@ -425,6 +425,7 @@ private[spark] class Executor( } } + setTaskFinishedAndClearInterruptStatus() execBackend.statusUpdate(taskId, TaskState.FINISHED, serializedResult) } catch {