Gunnar Schulze created SPARK-16293:
--------------------------------------
Summary: SparkAppHandle.getState() returns wrong state in
standalone mode if Spark application terminates unexpectedly
Key: SPARK-16293
URL: https://issues.apache.org/jira/browse/SPARK-16293
Project: Spark
Issue Type: Bug
Affects Versions: 1.6.1, 2.0.0
Reporter: Gunnar Schulze
When running a Spark application using
_org.apache.spark.launcher.SparkLauncher_ on a standalone cluster,
_org.apache.spark.launcher.SparkAppHandle.getState()_ returns _State.FINISHED_
instead of _State.FAILED_ if the Spark application terminates unexpectedly.
The bug can be reproduced using the following code snippet:
{code}
object FailingSparkApplication {
def main(args: Array[String]): Unit = {
val context = new SparkContext()
try {
throw new RuntimeException("Application terminated
unexpectedly")
} finally {
context.stop()
}
}
}
{code}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
