Перехват исключений для выполненного sql в искре ⇐ JAVA

[Anonymous]

У меня есть SQL-код, построенный динамически, и в нем есть поврежденные строки, например неправильное имя столбца или использование sm вместо sum.
Когда я выполняю sparksession.sql() для этой сгенерированной строки, все задание Spark завершается с ошибкой, как и ожидалось, и я вижу все журналы в журналах диспетчера ресурсов.
Есть ли способ перехватить это исключение в try-catch блокировать, обрабатывать это исключение и двигаться дальше по моей логике?

Подробнее здесь: https://stackoverflow.com/questions/585 ... l-in-spark