Flink CDC中MySQL cdc 2.4.1 出现这个原因是什么呢？
Flink CDC中MySQL cdc 2.4.1 出现这个原因是什么呢？Caused by: com.github.shyiko.mysql.binlog.event.deserialization.EventDataDeserializationException: Failed to deserialize data of EventHeaderV4{timestamp=1696639015000, eventType=ANNOTATE_ROWS, serverId=551963306, headerLength=19, dataLength=601467, nextPosition=169448226, flags=0}
execution.checkpointing.interval=10min
execution.checkpointing.tolerable-failed-checkpoints=100
restart-strategy=fixed-delay
restart-strategy.fixed-delay.attempts=2147483647
restart-strategy.fixed-delay.delay= 30s这几个参数加了
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
-
这个错误可能是由于MySQL CDC的版本和Flink的版本不匹配，或者是MySQL CDC的配置不正确导致的。
在MySQL CDC 2.4.1中，如果Flink的版本太低，可能会导致这个错误。因此，你需要确保Flink的版本与MySQL CDC的版本相匹配。
这个错误也可能是由于MySQL CDC的配置不正确导致的。你需要检查MySQL CDC的配置文件，确保所有的参数都被正确地配置。特别是execution.checkpointing.interval、execution.checkpointing.tolerable-failed-checkpoints、restart-strategy和restart-strategy.fixed-delay等参数的配置是否正确。2023-10-11 14:30:25赞同 展开评论 -
公众号：网络技术联盟站，InfoQ签约作者，阿里云社区签约作者，华为云 云享专家，BOSS直聘 创作王者，腾讯课堂创作领航员，博客+论坛：https://www.wljslmz.cn，工程师导航：https://www.wljslmz.com
应该是 Flink CDC 在反序列化 MySQL binlog 事件时出现了异常。具体来说，EventDataDeserializationException 表示无法将事件数据反序列化为相应的事件对象。
当数据库连接中断或发生超时时，可能导致未完成的事务被回滚，并导致一些 binlog 事件无法反序列化。
Flink CDC 支持的 MySQL 版本可能与使用的版本不兼容。在这种情况下，某些 binlog 事件可能无法正确解析。如果使用的 binlog 文件不完整或损坏，可能导致 Flink CDC 无法读取所有的 binlog 事件并从中恢复数据。
2023-10-11 07:48:12赞同 展开评论
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务，基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎，提高作业开发运维效率。