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

flinkcdc initial模式存量数据反复同步,不进入增量同步

日志输出了com.ververica.cdc.connectors.mysql.source.reader.MySqlSplitReader [] - Handling split change SplitAddition:[[MySqlSnapshotSplit{tableId=table_name, splitId='table_name:0', splitKeyType=[KeyID INT NOT NULL], splitStart=[32638595], splitEnd=null, highWatermark=null}]]
紧接着继续输出了e48a2b2a-27b7-11ea-993c-005056b353c3:1-80718, row=0, event=0} for split MySqlSnapshotSplit{tableId=table_name, splitId='table_name:0', splitKeyType=[KeyID INT NOT NULL], splitStart=null, splitEnd=[76895], highWatermark=null},又从头开始存量同步,这是为什么?有什么办法可以解决么

展开
收起
游客cifqniwczsyk2 2024-12-18 16:54:05 14 0
0 条回答
写回答
取消 提交回答

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

相关电子书

更多
低代码开发师(初级)实战教程 立即下载
冬季实战营第三期:MySQL数据库进阶实战 立即下载
阿里巴巴DevOps 最佳实践手册 立即下载