GracefulShutdown не работает, когда приложение закрывается из RestSubmissionClient или YarnClient

Question

При запуске приложения Spark "spark.streaming.stopGracefullyOnShutdown" имеет значение true

попытаться завершить приложение программно, используя JAVA API

1, используя RestSubmissionClient client = new RestSubmissionClient ( masterUrl); SubmitRestProtocolResponse statusResponse = client.killSubmission (submissionId);

с использованием getYarnClient (). KillApplication (appId);

В обоих случаях доза приложения не останавливается изящно

Но при уничтожении приложения с помощью

Kill - SIGTERM корректно завершит работу приложения.