Py4JJavaError - ошибка при отправке задания pyspark в dataproc
Я получаю сообщение об ошибке при попытке отправить задание pyspark в кластер dataproc.
Команда отправки в Gcloud:
Задания gcloud dataproc отправляют pyspark --cluster test-cluster migrate_db_table.py
Но получая ошибку ниже:
("Возникло исключение!!!", Py4JJavaError(u'Ошибка произошла при вызове o31311.jdbc.\ N ', JavaObject id=o31313))
Есть идеи об этой ошибке?