如何完全停止或关闭Spark Java应用程序

问题描述

我有一个用Java编写的spark应用程序,该应用程序每天运行。我需要根据情况退出程序(停止spark应用程序)。 我目前正在使用System.exit(0)关闭该应用程序。但是我看到应用程序状态在Yarn UI中显示为FAILED。

FinalStatus Reported by AM: FAILED

内部代码:

if(<some condition>){
    System.exit(0);
}

请建议如何从代码内部(在FinalStatus中显示“ SUCCESS”)完全停止/关闭spark应用程序。

解决方法

暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!

如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@)