各位好: 我通过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邮件归档
第一:一般这里需要reload 和lock table权限,这个权限包括你的replication slave 等权限用grant是授予不了的,测试建议先all。 第二:你可以登陆安装目录flink1.x/log,里面有详细的错误日志,不要只在client 里面哭想。我们连接的是mysql-cdc*来自志愿者整理的flink邮件归档
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。