使用flink mysql cdc时报错,原因是该用户没有mysql的reload权限:
Caused by: java.sql.SQLSyntaxErrorException: Access denied; you need (at least one of) the RELOAD privilege(s) for this operation
at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:120)
at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:97)
at com.mysql.cj.jdbc.exceptions.SQLExceptionsMapping.translateException(SQLExceptionsMapping.java:122)
at com.mysql.cj.jdbc.StatementImpl.executeInternal(StatementImpl.java:782)
at com.mysql.cj.jdbc.StatementImpl.execute(StatementImpl.java:666)
at io.debezium.jdbc.JdbcConnection.executeWithoutCommitting(JdbcConnection.java:1201)
at io.debezium.connector.mysql.SnapshotReader.execute(SnapshotReader.java:465)
... 3 more
关于mysql的reload权限可以参考:https://blog.csdn.net/q3dxdx/article/details/51005613
这类权限的授权不是针对某个数据库的,因此须使用on *.*
来进行:
grant reload on *.* to 'user_name'@'%';