有没有办法从启动程序线程获取启动程序异常?
SparkLauncher launcher = new SparkLauncher()
.setSparkHome("sparkhome")
.setMaster("yarn-cluster")
.setAppResource("spark job jar file")
.setMainClass("spark job driver class")
.setAppName("appname")
.addAppArgs(argsArray)
.setVerbose(true)
.addSparkArg("--verbose");
SparkAppHandle handle = launcher.startApplication(new LauncherListener());
需要获取引发的异常 launcher.startApplication()
方法。
注意-try catch block不起作用 launcher.startApplication()
方法创建单独的线程。
暂无答案!
目前还没有任何答案,快来回答吧!