一、背景
在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遇到此問題也可以嘗試用該方法解決。