This is an automated email from the ASF dual-hosted git repository.
dongjoon pushed a commit to branch branch-4.1
in repository https://gitbox.apache.org/repos/asf/spark.git
The following commit(s) were added to refs/heads/branch-4.1 by this push:
new 24df26b9bd60 [SPARK-54087][CORE][FOLLOWUP] Spark Executor launch task
failed return task killed message should not special handling OOM
24df26b9bd60 is described below
commit 24df26b9bd60f9282afeba0f82ff791872924677
Author: Angerszhuuuu <[email protected]>
AuthorDate: Mon Dec 8 08:44:32 2025 -0800
[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
https://github.com/apache/spark/pull/52792#discussion_r2594690824
### 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 <[email protected]>
Signed-off-by: Dongjoon Hyun <[email protected]>
(cherry picked from commit 6a606163ace44728b4eab4197bce977eef5db7f7)
Signed-off-by: Dongjoon Hyun <[email protected]>
---
core/src/main/scala/org/apache/spark/executor/Executor.scala | 4 ----
1 file changed, 4 deletions(-)
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 53c791a3446c..aa17f954a7d9 100644
--- a/core/src/main/scala/org/apache/spark/executor/Executor.scala
+++ b/core/src/main/scala/org/apache/spark/executor/Executor.scala
@@ -407,10 +407,6 @@ private[spark] class Executor(
TaskState.FAILED,
env.closureSerializer.newInstance().serialize(new
ExceptionFailure(t, Seq.empty)))
} catch {
- case oom: OutOfMemoryError =>
- logError(log"Executor update launching task ${MDC(TASK_NAME,
taskDescription.name)} " +
- log"failed status failed, reason: ${MDC(REASON,
oom.getMessage)}")
- System.exit(SparkExitCode.OOM)
case t: Throwable =>
logError(log"Executor update launching task ${MDC(TASK_NAME,
taskDescription.name)} " +
log"failed status failed, reason: ${MDC(REASON, t.getMessage)}")
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
