栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 面试经验 > 面试问答

pyspark mysql jdbc load调用o23.load时发生错误没有合适的驱动程序

面试问答 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

pyspark mysql jdbc load调用o23.load时发生错误没有合适的驱动程序

当我尝试将脚本写入MySQL时,我遇到了“ java.sql.SQLException:没有合适的驱动程序”。

这是我为解决此问题所做的工作。

在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_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中替换

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


转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/416639.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号