开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

Flink CDC里earliest-offset:跳过快照阶段,接下来怎么做?

Flink CDC里earliest-offset:跳过快照阶段,从可读取的最早 binlog 位点开始读取
设置这个后,比如我保留七天的binlog,他是会从这七天最早的起点开始读取吗?可是老师,我遇到一个问题,我的结果表少了一批数据,我就设置这个参数去补,结果就读了几万条数据就开始增量同步了,然后丢的数据依然没有补回来,这是什么原因呢?因为在mysql有今天凌晨两点的数据,然后我的sink端却没有.老师这个怎么搞指导下呗,或者官网文档,难道会有数据库有数据,但是没有记录binlog的情况.

展开
收起
小小鹿鹿鹿 2024-04-15 19:56:46 23 0
1 条回答
写回答
取消 提交回答

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

相关电子书

更多
Flink CDC Meetup PPT - 龚中强 立即下载
Flink CDC Meetup PPT - 王赫 立即下载
Flink CDC Meetup PPT - 覃立辉 立即下载
http://www.vxiaotou.com