Блог

Главная - Вопросы по программированию - Выборка исключения из потока запуска spark

Выборка исключения из потока запуска spark

#multithreading #apache-spark #exception

#многопоточность #apache-spark #исключение

Вопрос:

Есть ли способ извлечь исключение запуска из потока запуска?

 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 не работает, так как launcher.startApplication() метод создает отдельный поток.