开发者社区 > 大数据与机器学习 > 正文

我们通过Flink CDC时间戳偏移量读取mysql binlog,设置了checkpoint,一?

我们通过Flink CDC时间戳偏移量读取mysql binlog,设置了checkpoint,一个taskmanager挂掉,这个任务转移到另一个taskmanager上,报如下错误: Caused by: com.github.shyiko.mysql.binlog.network.ServerException: event read from binlog did not pass crc check; the first event '' at 9451498, the last event read from '/mysql/mysql8636/log/binlog/mysql_bin.000018' at 123, the last byte read from '/mysql/mysql8636/log/binlog/mysql_bin.000018' at 19937258. at com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:944)但是通过initial的初始化读的话,一个taskmanager挂掉,任务转移到另一个taskmanager上就不会报错。

展开
收起
真的很搞笑 2023-05-23 18:02:46 179 0
0 条回答
写回答
取消 提交回答

大数据领域前沿技术分享与交流,这里不止有技术干货、学习心得、企业实践、社区活动,还有未来。

相关产品

  • 实时计算 Flink版
  • 相关电子书

    更多
    Flink CDC Meetup PPT - 龚中强 立即下载
    Flink CDC Meetup PPT - 王赫 立即下载
    Flink CDC Meetup PPT - 覃立辉 立即下载