我有一个用java编写的spark应用程序,每天都在运行。我有一个条件的基础上退出程序(停止Spark应用程序)的要求。我当前正在使用system.exit(0)关闭应用程序。但我看到应用程序的状态在yarn ui中显示为failed。
FinalStatus Reported by AM: FAILED
内部代码:
if(<some condition>){
System.exit(0);
}
请建议如何从代码内部完全停止/关闭spark应用程序,其中finalstatus显示“success”。
暂无答案!
目前还没有任何答案,快来回答吧!