Details
-
Bug
-
Status: Resolved
-
Major
-
Resolution: Incomplete
-
2.4.3
-
None
-
spark-2.4.3
Description
While starting the Spark Application "spark.streaming.stopGracefullyOnShutdown" is set to true
try to terminate the application programatically using JAVA API
1 using RestSubmissionClient client = new RestSubmissionClient(masterUrl);
SubmitRestProtocolResponse statusResponse = client.killSubmission(submissionId);
2. using getYarnClient().killApplication(appId);
In both the cases Application dose not stop gracefully
But killing the Application using
Kill -SIGTERM <pid> will shutdown the application gracefully.
Expected : Application should have terminated gracefully in all cases when spark.streaming.stopGracefullyOnShutdown is set