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这几个参数加了

展开

收起

真的很搞笑 2023-10-10 19:02:18 147 0

2 条回答

写回答

取消提交回答

听风de歌

这个错误可能是由于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

赞同展开评论打赏
wljslmz

公众号：网络技术联盟站，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

赞同展开评论打赏