Вызовите getNextException из pyspark - PullRequest
Новая
       13

Вызовите getNextException из pyspark

0 голосов
/ 04 октября 2018

Я пытаюсь записать данные в db2 через pyspark и хочу получать более качественные сообщения об ошибках при сбоях.Я знаю, что могу получить сообщения об ошибках Java, например: 

from py4j.protocol import Py4JJavaError

try:
    data_frame.write.jdbc('jdbc...', table='some_table', properties='my jdbc properties')
except Py4JJavaError as err:
    print(err.java_exception)

Но это возвращает что-то вроде 

com.ibm.db2.jcc.am.BatchUpdateException...
Use getNextException() to retrieve the exceptions for specific batched elements.

Есть ли способ использовать getNextException() через pyspark, чтобы получитьподробности ошибки?

...