Mysql
 sql >> база данни >  >> RDS >> Mysql

pyspark mysql jdbc load Възникна грешка при извикване на o23.load Няма подходящ драйвер

Попаднах на „java.sql.SQLException:Няма подходящ драйвер“, когато се опитах да накарам скрипта ми да пише в MySQL.

Ето какво направих, за да поправя това.

В script.py

df.write.jdbc(url="jdbc:mysql://localhost:3333/my_database"
                  "?user=my_user&password=my_password",
              table="my_table",
              mode="append",
              properties={"driver": 'com.mysql.jdbc.Driver'})

След това стартирах spark-submit по този начин

SPARK_HOME=/usr/local/Cellar/apache-spark/1.6.1/libexec spark-submit --packages mysql:mysql-connector-java:5.1.39 ./script.py

Имайте предвид, че SPARK_HOME е специфичен за мястото, където е инсталирана spark. За вашата среда това https://github.com/sequenceiq/docker -spark/blob/master/README.md може да помогне.

В случай, че всичко по-горе е объркващо, опитайте това:
В t.py replace

sqlContext.read.format("jdbc").option("url",url).option("dbtable","people").load()

с

sqlContext.read.format("jdbc").option("dbtable","people").option("driver", 'com.mysql.jdbc.Driver').load()

И стартирайте това с

spark-submit --packages mysql:mysql-connector-java:5.1.39 --master local[4] t.py


  1. Database
  2.   
  3. Mysql
  4.   
  5. Oracle
  6.   
  7. Sqlserver
  8.   
  9. PostgreSQL
  10.   
  11. Access
  12.   
  13. SQLite
  14.   
  15. MariaDB
  1. Mysql избира записи с изместване

  2. Свържете се с MySQL DB с помощта на многопоточност

  3. Намерете липсващите дати и ги добавете в резултат - MySql

  4. Импортиране на XML със съдържание, посочено като атрибути, в MySQL таблица?

  5. Моделиране на варианти на продукта