我通过火花发射器提交火花应用程序。我不会等到应用程序完成，而是需要让路来杀死应用程序。
SparkAppHandle spark = new SparkLauncher()
.setAppResource("/usr/local/myapp.jar")
.setMainClass("com.myapp.app")
.setMaster("yarn")
.setDeployMode( "cluster")
.startApplication( this);
并获取应用程序 ID。
String id = spark.getAppId(); // how to wait untill not UNKONWN?
SparkAppHandle curApp = ???.getHandleByID( id); // how to get?
如何通过 App ID 获取 SparkAppHnadle，以便调用 destory() 方法。
没有办法通过它的其他信息来获取 SparkAppHandle。我通过制作以 appID 或唯一字符串为键、 SparkAppHandle 作为值的 hashmap 解决了这个问题。这不是根本的解决方案，但它是迄今为止唯一的解决方案。
本文收集自互联网，转载请注明来源。
如有侵权，请联系[email protected] 删除。
我来说两句