[SPARK-54774][CORE] k8s submit failed should keep same exit code with user code

AngersZhuuuu · AngersZhuuuu · commit 4c6b561eab54 · 2025-12-19T17:39:28.000+08:00
diff --git a/core/src/main/scala/org/apache/spark/deploy/SparkSubmit.scala b/core/src/main/scala/org/apache/spark/deploy/SparkSubmit.scala
@@ -1047,7 +1047,7 @@ private[spark] class SparkSubmit extends Logging {
           !isSqlShell(args.mainClass) && !isThriftServer(args.mainClass) &&
           !isConnectServer(args.mainClass)) {
         try {
-          SparkContext.getActive.foreach(_.stop())
+          SparkContext.getActive.foreach(_.stop(exitCode))
         } catch {
           case e: Throwable => logError("Failed to close SparkContext", e)
         }

Original file line number	Diff line number	Diff line change
`@@ -1047,7 +1047,7 @@ private[spark] class SparkSubmit extends Logging {`
`1047`	`1047`	`!isSqlShell(args.mainClass) && !isThriftServer(args.mainClass) &&`
`1048`	`1048`	`!isConnectServer(args.mainClass)) {`
`1049`	`1049`	`try {`
`1050`		`- SparkContext.getActive.foreach(_.stop())`
	`1050`	`+ SparkContext.getActive.foreach(_.stop(exitCode))`
`1051`	`1051`	`} catch {`
`1052`	`1052`	`case e: Throwable => logError("Failed to close SparkContext", e)`
`1053`	`1053`	`}`