文章 2024-05-23 来自:开发者社区

实时计算 Flink版操作报错之从specified offset启动没有问题,但是停机后从savepoint恢复则报错binlog被purge(实际文件还在),如何处理

问题一:flink cdc (2.4.1) 重启的时候作为参数传给flink cdc吗? flink cdc (2.4.1) 从specified offset启动没有问题,但是停机后从savepoint恢复则报错binlog被purge(实际文件还在)。是需要停机前手工记录gtid,重启的时候作为参数传给flink cdc吗? 参考回答: Flink...

实时计算 Flink版操作报错之从specified offset启动没有问题,但是停机后从savepoint恢复则报错binlog被purge(实际文件还在),如何处理
问答 2024-03-11 来自:开发者社区

flinkcdc为什么从savepoint启动后发现新加的表是从最新的binlog开始同步数据的?

做flink cdc2doris的操作时,新建一个任务,设置从最早的 binlog 开始同步(scan.startup.mode=earliest-offset)没有问题,然后新加一张表,从savepoint启动后发现新加的表是从最新的binlog开始同步数据的。是正常现象么?

问答 2023-08-16 来自:开发者社区

flinkcdc2.2版本从savepoint重启无法继续读取Binlog的情况怎么解决?

flinkcdc2.2版本从savepoint重启无法继续读取Binlog的情况怎么解决?代码里面配置所有表,也就是*。

问答 2022-08-12 来自:开发者社区

想问下大佬们,mysql cdc,从savepoint重新启动后,就不能继续消费到binlog的数据

想问下大佬们,mysql cdc,从savepoint重新启动后,就不能继续消费到binlog的数据,也无报错,这是为什么呀?

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等