探索云世界
使用Flink CDC 同步MySQl。配置了多张表， 有一张A表删除了字段，然后停止同步，将A表移除同步队列，过了一段时间之后将A表加回去，但是读取Schema的时候还是可以读取到已经删除的字段，导致报错和实际字段数量不一致，这种情况要怎么处理？消费点位是和单张表绑定的么？我是同步多张表，按理说消费点位已经到最新了我移除了这个表，然后flink任务继续跑，从没有这个表的savepoint启动，这个时候应该是当成新表来做快照和增量同步吧?
写回答
重置一下消费位点 在更改表结构之后 .消费位点的确定 和你当前客户端服务绑定的这个库数据库白名单表列表有关哦 列表就一个表就相当于和单表绑定 不应该是移除这个表 而是跳过这个位点之后 找到有效position
show binlog events in 日志文件 查找
最终兜底方案 datax 工具同步最新数据 后 StartupOptions.latest() 按照当前时间立即执行 .此回答来自钉群Flink CDC 社区。
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务，基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎，提高作业开发运维效率。
