Skip to content

Commit 24df26b

Browse files
AngersZhuuuudongjoon-hyun
authored andcommitted
[SPARK-54087][CORE][FOLLOWUP] Spark Executor launch task failed return task killed message should not special handling OOM
### What changes were proposed in this pull request? Follow comment #52792 (comment) ### Why are the changes needed? Follow comment ### Does this PR introduce _any_ user-facing change? No ### How was this patch tested? No need ### Was this patch authored or co-authored using generative AI tooling? No Closes #53379 from AngersZhuuuu/SPARK-54087-FOLLOWUP. Authored-by: Angerszhuuuu <angers.zhu@gmail.com> Signed-off-by: Dongjoon Hyun <dongjoon@apache.org> (cherry picked from commit 6a60616) Signed-off-by: Dongjoon Hyun <dongjoon@apache.org>
1 parent 050c3a7 commit 24df26b

File tree

1 file changed

+0
-4
lines changed

1 file changed

+0
-4
lines changed

core/src/main/scala/org/apache/spark/executor/Executor.scala

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -407,10 +407,6 @@ private[spark] class Executor(
407407
TaskState.FAILED,
408408
env.closureSerializer.newInstance().serialize(new ExceptionFailure(t, Seq.empty)))
409409
} catch {
410-
case oom: OutOfMemoryError =>
411-
logError(log"Executor update launching task ${MDC(TASK_NAME, taskDescription.name)} " +
412-
log"failed status failed, reason: ${MDC(REASON, oom.getMessage)}")
413-
System.exit(SparkExitCode.OOM)
414410
case t: Throwable =>
415411
logError(log"Executor update launching task ${MDC(TASK_NAME, taskDescription.name)} " +
416412
log"failed status failed, reason: ${MDC(REASON, t.getMessage)}")

0 commit comments

Comments
 (0)