Re: 【闫云鹏】Flink cdc 连接mysql5.7.25报错

Wed, 26 Aug 2020 01:11:12 -0700 

有大佬帮忙看看？

闫云鹏
DXM 支付业务部
地址：北京市海淀区西北旺东路度小满金融总部
邮编：100085
手机：13693668213
邮箱：yanyunp...@duxiaoman.com<mailto:yanyunp...@duxiaoman.com>

度小满金融

精于科技 值得信赖




发件人: "Yan,Yunpeng(DXM,PB)" <yanyunp...@duxiaoman.com>
答复: "user-zh@flink.apache.org" <user-zh@flink.apache.org>
日期: 2020年8月26日 星期三 11:24
收件人: "user-zh@flink.apache.org" <user-zh@flink.apache.org>
抄送: "Li,Qian(DXM,PB)" <liq...@duxiaoman.com>
主题: 【闫云鹏】Flink cdc 连接mysql5.7.25报错

Hi all:
       使用flink cdc连接mysql 5.7.25  使用默认的8.0.16的mysql驱动报错如下信息
       Caused by: java.sql.SQLNonTransientConnectionException: 
CLIENT_PLUGIN_AUTH is required
       at 
com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:110)
       at 
com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:97)
       at 
com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:89)
       at 
com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:63)
       at 
com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:73)
       at 
com.mysql.cj.jdbc.exceptions.SQLExceptionsMapping.translateException(SQLExceptionsMapping.java:79)
       at com.mysql.cj.jdbc.ConnectionImpl.createNewIO(ConnectionImpl.java:835)
       at com.mysql.cj.jdbc.ConnectionImpl.<init>(ConnectionImpl.java:455)
       at com.mysql.cj.jdbc.ConnectionImpl.getInstance(ConnectionImpl.java:240)
       at 
com.mysql.cj.jdbc.NonRegisteringDriver.connect(NonRegisteringDriver.java:199)
       at 
io.debezium.jdbc.JdbcConnection.lambda$patternBasedFactory$1(JdbcConnection.java:190)
       at io.debezium.jdbc.JdbcConnection.connection(JdbcConnection.java:788)
       at io.debezium.jdbc.JdbcConnection.connection(JdbcConnection.java:783)
       at io.debezium.jdbc.JdbcConnection.connect(JdbcConnection.java:329)
       at 
io.debezium.connector.mysql.MySqlJdbcContext.querySystemVariables(MySqlJdbcContext.java:325)
       ... 11 more
       数据库账户已授权，尝试降低驱动版本
       使用
<dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
    <version>5.1.47</version>
</dependency>
       报错
Caused by: java.lang.ClassNotFoundException: com.mysql.cj.jdbc.Driver
       at java.net.URLClassLoader.findClass(URLClassLoader.java:382)
       at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
       at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:349)
       at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
       ... 8 more

       在MySQLSource中手动添加驱动配置

props.setProperty("database.jdbc.driver", "com.mysql.jdbc.Driver");
不生效，还是使用默认的驱动

尝试修改


<debezium.version>1.2.0.Final</debezium.version>
发现依赖比较多，请求有没有更好的方式来兼容或者传入驱动
闫云鹏
DXM 支付业务部
地址：北京市海淀区西北旺东路度小满金融总部
邮编：100085
手机：13693668213
邮箱：yanyunp...@duxiaoman.com<mailto:yanyunp...@duxiaoman.com>

度小满金融

精于科技 值得信赖

回复