从spark launcher线程获取异常

rjzwgtxy  于 2021-05-27  发布在  Spark
关注(0)|答案(0)|浏览(338)

有没有办法从启动程序线程获取启动程序异常?

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() 方法创建单独的线程。

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题