开发者社区> 问答> 正文

mysql cdc配置问题应该怎么办?

各位好:         我通过mysql cdc链接mysql(mariadb)一直不成功。网上也搜不到有效的解决方法。

        用pyflink调试就一直运行也没数据也不报错。用flink sql就报java.net.ConnectException: Connection refused。

      

        用slave可以远程连接mysql,也执行了 grant replication client, replication slave on . to 'slave'@'%' identified by 'slave';

sql和mysql的配置信息在下方,期盼大佬解答

flink sql如下:

CREATE TEMPORARY TABLE xin_test (

>           id INT,

>           name STRING

>         ) WITH (

>             'connector' = 'mysql-cdc',

>             'hostname' = '..*.203',

>             'port' = '3306',

>             'username' = 'slave',

>             'password' = 'slave',

>             'database-name' = 'test',

>             'table-name' = 'test',

>             'server-id' = '10001',

>             'server-time-zone' = 'Asia/Shanghai'

>         )

> ;

Flink SQL> select * from xin_test;

[ERROR] Could not execute SQL statement. Reason:

java.net.ConnectException: Connection refused

mysql的配置信息:

[mysqld]

datadir=/var/lib/mysql

socket=/var/lib/mysql/mysql.sock

symbolic-links=0

log-bin=mysql-bin                                

server-id=10001                                  

replicate-do-db=test 

                          

[mysqld_safe]

log-error=/var/log/mariadb/mariadb.log

pid-file=/var/run/mariadb/mariadb.pid*来自志愿者整理的flink邮件归档

展开
收起
moonlightdisco 2021-12-01 14:09:28 1133 0
1 条回答
写回答
取消 提交回答
  • 第一:一般这里需要reload 和lock table权限,这个权限包括你的replication slave 等权限用grant是授予不了的,测试建议先all。 第二:你可以登陆安装目录flink1.x/log,里面有详细的错误日志,不要只在client 里面哭想。我们连接的是mysql-cdc*来自志愿者整理的flink邮件归档

    2021-12-01 14:10:07
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
阿里云MySQL云数据库产品体系介绍 立即下载
One Box: 解读事务与分析一体化数据库 HybridDB for MySQL 立即下载
One Box:解读事务与分析一体化数据库HybridDB for MySQL 立即下载

相关镜像