问题一:Flink CDC启动kubernetes-session.sh,为什么一直报错?
Flink CDC启动kubernetes-session.sh,为什么一直报错?
参考回答:
把这个clusterid 放在flink-conf文件中
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/601423
问题二:Flink CDC在使用oraclecdc的时候也遇见了这个问题,如何解决呢?
Flink CDC在使用oraclecdc的时候也遇见了这个问题,如何解决呢?
参考回答:
https://github.com/ververica/flink-cdc-connectors/pull/2479/files这个sql。
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/601412
问题三:Flink CDC按时间恢复报这个错怎么处理?
Flink CDC按时间恢复报这个错怎么处理?
参考回答:
根据错误提示,Flink CDC在尝试读取binlog时发现所需的binlog位置不再可用。这可能是由于MySQL的binlog已被清理或者Flink CDC作业重启后binlog起点不再有效。解决方法通常是重新配置Flink CDC作业,使其在启动时能从最新的binlog位置开始读取,或者在必要时采取全量快照方式初始化数据同步。具体做法可查阅Flink CDC的相关文档,了解如何配置checkpoint策略或使用Snapshot模式启动任务。
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/601410
问题四:Flink CDC会不会造成未按数据修改顺序写出外部存储导致数据错误呢?
Flink CDC会不会造成未按数据修改顺序写出外部存储导致数据错误呢?
参考回答:
如果按照主键进行key by的话 就没问题 保证主键数据的顺序性
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/601407
问题五:Flink CDC 知道这个是什么原因导致的吗?
Flink CDC 知道这个是什么原因导致的吗?
参考回答:
延时等于cp是正常的,他同步需要时间,如果你想要快一点, 就把checpoint调小单线程执行的, 在mysql的binlog会有offset记录, 你不用担心顺序问题 。
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/601404