diff --git a/server/src/main/scala/org/apache/livy/server/batch/BatchSession.scala b/server/src/main/scala/org/apache/livy/server/batch/BatchSession.scala index c15057bc5..37fb6dc0c 100644 --- a/server/src/main/scala/org/apache/livy/server/batch/BatchSession.scala +++ b/server/src/main/scala/org/apache/livy/server/batch/BatchSession.scala @@ -98,6 +98,7 @@ object BatchSession extends Logging { case 0 => case exitCode => warn(s"spark-submit exited with code $exitCode") + s.stateChanged(SparkApp.State.STARTING, SparkApp.State.FAILED) } } finally { childProcesses.decrementAndGet()