Tôi gặp phải "java.sql.SQLException:Không có trình điều khiển phù hợp" khi tôi cố gắng ghi tập lệnh của mình vào MySQL.
Đây là những gì tôi đã làm để khắc phục điều đó.
Trong 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'})
Sau đó, tôi chạy spark-submit theo cách này
SPARK_HOME=/usr/local/Cellar/apache-spark/1.6.1/libexec spark-submit --packages mysql:mysql-connector-java:5.1.39 ./script.py
Lưu ý rằng SPARK_HOME dành riêng cho nơi cài đặt tia lửa. Đối với môi trường của bạn, https://github.com/sequenceiq/docker -spark / blob / master / README.md có thể hữu ích.
Trong trường hợp tất cả những điều trên gây nhầm lẫn, hãy thử cách này:
Trong t.py thay thế
sqlContext.read.format("jdbc").option("url",url).option("dbtable","people").load()
với
sqlContext.read.format("jdbc").option("dbtable","people").option("driver", 'com.mysql.jdbc.Driver').load()
Và chạy điều đó với
spark-submit --packages mysql:mysql-connector-java:5.1.39 --master local[4] t.py