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

[Anonymous]

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

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