Я пытаюсь записать фрейм данных pyspark в базу данных Postgres со следующим кодом:
mode = "overwrite"
url = "jdbc:postgresql://host/database"
properties = {"user": "user","password": "password","driver": "org.postgresql.Driver"}
dfTestWrite.write.jdbc(url=url, table="test_result", mode=mode, properties=properties)
Однако я получаю следующую ошибку:
An error occurred while calling o236.jdbc.
: java.lang.ClassNotFoundException: org.postgresql.Driver
У меня естьнашел несколько вопросов SO, которые касаются аналогичной проблемы, но не нашел ничего, что могло бы помочь. Я добавил документацию AWS здесь , чтобы добавить конфигурацию, и с консоли EMR все выглядит так, как будто она прошла успешно:
Что я делаю не так?