2301_79564221 2024-04-03 09:46 采纳率: 0%
浏览 8
已结题

flink如何读取pxc集群的binlog日志

flink无法读取mysql的binlog日志
最近有个需求,需要使用flink实时同步mysql的数据到另一个mysql,后来发现源端的mysql是使用pxc的方式部署的集群模式。不知道是否和这个集群有关系,但现在的问题就是flink无法或许这个库的日志,如果更换其他的库可以正常实时增量查询
下面是代码,运行在flink sql client中,


SET execution.checkpointing.interval = 1s;

CREATE TABLE flink_cdc (
`name` string,
`sex` string,
`age` string,
PRIMARY KEY (`name`) NOT ENFORCED
) WITH (
--'connector' = 'mysql-cdc',
--'hostname' = '11111',
--'port' = '3306',
--'username' = 'root',
--'password' = '123456',
--'database-name' = 'museum',
--'table-name' = 'flink_cdc'
--);
'connector' = 'mysql-cdc',
'hostname' = '10.130.1.11',
'port' = '3306',
'username' = 'root',
'password' = '%tgb6YHN',
'database-name' = 'museum',
'table-name' = 'flink_source'
);


CREATE TABLE flink_test (
`name` string,
`sex` string,
`age` string,
PRIMARY KEY (`name`) NOT ENFORCED
) WITH (
'connector' = 'jdbc',
'url' = 'jdbc:mysql://xxxx:4506/museum',
'driver' = 'com.mysql.jdbc.Driver',
'username' = 'root',
'password' = '123456',
'table-name' = 'flink_test'
);

insert into flink_test select * from flink_cdc;
  • 写回答

13条回答 默认 最新

  • 喝茶品人生 2024-04-03 09:50
    关注

    测试过 Flink 连接集群的端口吗?可以把日志附上

    img

    评论 编辑记录

报告相同问题?

问题事件

  • 已结题 (查看结题原因) 4月3日
  • 创建了问题 4月3日

悬赏问题

  • ¥15 import arcpy出现importing _arcgisscripting 找不到相关程序
  • ¥15 onvif+openssl,vs2022编译openssl64
  • ¥15 iOS 自定义输入法-第三方输入法
  • ¥15 很想要一个很好的答案或提示
  • ¥15 扫描项目中发现AndroidOS.Agent、Android/SmsThief.LI!tr
  • ¥15 怀疑手机被监控,请问怎么解决和防止
  • ¥15 Qt下使用tcp获取数据的详细操作
  • ¥15 idea右下角设置编码是灰色的
  • ¥15 全志H618ROM新增分区
  • ¥15 在grasshopper里DrawViewportWires更改预览后,禁用电池仍然显示