Flink CDC中mysqlcdc 2.4.1 出现这个问题 ?com.github.shyiko.mysql.binlog.event.deserialization.missingtablemapeventexception: No TableMapEventData has been found for table id:209659. Usually that means that you have started reading binary log 'within the logical event group' (e.g. from WRITE_ROWS and not proceeding TABLE_MAP2.0.2 已经解决了 我现在升级到2.4.1了 是还需要做什么参数设置吗
如果您的 Flink CDC 仍然是 2.4.1 版本,请按照以下步骤尝试解决问题:
如果上述方法都不能解决,请尝试重新启动 Flink CDC,并重新部署 MySQL 数据库服务器,并保持数据库的版本与插件版本一致。
根据你提供的问题描述,你在使用Flink CDC连接MySQL数据库时遇到了一个关于TableMapEventData缺失的问题。这个问题通常发生在读取二进制日志的过程中,从一个逻辑事件组内开始读取(例如从WRITE_ROWS事件开始,而不是从TABLE_MAP事件开始)。
在MySQL的二进制日志格式中,TABLE_MAP事件用于描述表的结构信息,而WRITE_ROWS等事件用于描述具体的操作。因此,如果在逻辑事件组中没有找到TABLE_MAP事件,就意味着没有找到表的映射信息,从而引发了这个异常。
根据你提到的版本信息,问题在2.4.1版本中出现了,但2.0.2版本已经解决了。如果你从2.0.2版本升级到2.4.1版本后遇到了同样的问题,可能需要进行一些参数设置来确保正确地读取二进制日志。
以下是一些可能有帮助的参数设置:
mysql-cdc-deserializer.table-map-event-enabled
为true
。这将启用TableMap事件的解析和映射。mysql-cdc-deserializer.start-point
参数来实现。版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。