一、背景

在Spark中，将DStream写入到MySQL出现错误：java.sql.SQLException: Access denied for user 'root'@'localhost' (using password: YES)

二、解决办法

由于代码中连接数据库的用户名和密码都没有错误，经过上网查询之后，发现是数据库权限问题，使用以下方法成功解决：

登录MySQL，输入以下命令：

mysql> GRANT ALL PRIVILEGES ON *.* TO 'root'@'localhost' IDENTIFIED BY 'password' WITH GRANT OPTION;

mysql> flush privileges;

注意要将第一条命令中的password换成自己的数据库密码。

其实不只是在Spark(scala)中，在java中连接MySQL遇到此问题也可以尝试用该方法解决。