pyspark 使用jdbc 连接mysql 数据库报错 Access denied for user 'root'@'localhost'
2020-02-15 09:55
411 查看
在使用jdbc开启pyspark shell
下载jar包:https://dev.mysql.com/downloads/connector/j/
tar -zxf mysql-connector-java-8.0.13.tar.gz /usr/local/spark/jars/
在启动pyspark 时 指定--jars参数
pyspark --jars /usr/local/spark/jars/mysql-connector-java-8.0.13/mysql-connector-java-8.0.13.jar --driver-class-path /usr/local/spark/jars/mysql-connector-java-8.0.13/mysql-connector-java-8.0.13.jar
在pyspark shell 中连接mysql数据库时出错
jdbcDF = spark.read.format("jdbc").option("url", "jdbc:mysql://localhost:3306/spark").option("driver","com.mysql.jdbc.Driver").option("dbtable", "student").option("user", "root").option("password", "hadoop").load()
报错显示:
Py4JJavaError: An error occurred while calling o31.load.
: java.sql.SQLException: Access denied for user 'root'@'localhost'
最后在mysql数据库中重新建立了一个 用户,为这个用户指定数据库权限。然后使用这个用户连接数据库,没有报错。
转载于:https://www.cnblogs.com/Ray-Lei/p/9989664.html
- 点赞
- 收藏
- 分享
- 文章举报
相关文章推荐
- MySQL在Windows10下的安装
- MySQL的日期格式化
- 如何启动/停止/重启MySQL
- mysql主从同步
- yum安装指定版本的mysql
- Mysql读写分离——主从数据库+Atlas
- mysql基础
- MYSQL约束
- mysql workbench update error code:1175
- mysql show status详解
- mysql5.7.25msi(win10安装教程)
- mysql5.7修改密码及注意事项
- mysql无法启动
- 记一次mysql查询or、and并用查询
- MySQL修改root密码的4种方法
- 初识MySQL
- MySQL 约束-实例
- MySQL字符集的转换过程
- MySQL备份与恢复
- com.mysql.jdbc.exceptions.jdbc4.CommunicationsException: Communications link failure