问题一:Flink CDC有没有遇到过同步MySQL一直卡在某个binlog文件?
Flink CDC有没有遇到过同步MySQL一直卡在某个binlog文件?数据库已经确认后续的binlog都生成了 io
日志:
io.debezium.connector.mysql.MySqlStreamingChangeEventSource [] - Stopped reading binlog after 0 events, no new offset was recorded io.debezium.connector.mysql.MySqlStreamingChangeEventSource [] - Connected to MySQL binlog atMySQL cdc
参考回答:
一般是升级版本就可以
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/567865
问题二:Flink CDC中managed memory一直都是100%使用量?
Flink CDC中managed memory一直都是100%使用量?
参考回答:
你用了RocksDB的状态后端,它就是满的,如果报内存溢出,考虑增加其他的部分
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/567864
问题三:Flink CDC这个是正常情况吗?
Flink CDC这个是正常情况吗?cdc全量同步出现这个2.4.1
参考回答:
你是不是,升级版本从savepoint启动的,这里显示的cdc版本还是2.2.1
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/567860
问题四:Flink CDC这是什么原因?
Flink CDC这是什么原因?
跑不起来啊
参考回答:
用 java 跑
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/567859
问题五:PG的FLINK CDC ,有人用吗? PG数据库开启逻辑复制,复制标识必须设置为F吗?
PG的FLINK CDC ,有人用吗? PG数据库开启逻辑复制,复制标识必须设置为F吗?主键D不行吗?
参考回答:
在使用Flink CDC来处理PostgreSQL数据库时,确实需要设置表的复制标识为FULL。这是因为在执行UPDATE/DELETE操作时,Debezium会检查"before"字段是否为null,如果为null,则会报错。因此,你需要在PostgreSQL中运行以下命令来设置表的复制标识为FULL:
ALTER TABLE public.resident REPLICA IDENTITY FULL;
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/567858