开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

flinkcdc2.3,mysql5.7在开启了row以后还是有这个问题?

flinkcdc2.3,mysql5.7在开启了row以后还是有这个问题?以前用的类型是mixed,设置了全局的为row,但是没有重启,删除了所有以前的binlog,binlog probably contains events generated with statement or mixed based replication format 官方的issue里说1.5已经修复,我看flinkcdc2.3里面用的是1.6的,有没有遇到相同情况的image.png

展开
收起
真的很搞笑 2023-05-09 13:21:59 92 0
1 条回答
写回答
取消 提交回答
  • 存在即是合理

    可能是因为Flink CDC 2.3默认使用的是1.6版本的MySQL Connector,而该版本的Connector在处理binlog时可能会存在一些问题。

    官方的issue中提到1.5版本已经修复了这个问题,但是如果您使用的是2.3版本,则需要等待Flink CDC 2.4或更高版本的发布,以获得更好的兼容性和稳定性。

    另外,如果您删除了所有以前的binlog,那么您需要确保在启动Flink CDC时正确配置了源和目标数据库的连接信息,并且启用了适当的binlog格式(例如ROW)。如果问题仍然存在,请尝试使用其他工具(例如mysqldump)手动导出数据并将其导入到目标数据库中,以确定是否存在任何数据转换或解析方面的问题。

    2023-05-09 16:32:21
    赞同 展开评论 打赏

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

相关电子书

更多
搭建电商项目架构连接MySQL 立即下载
搭建4层电商项目架构,实战连接MySQL 立即下载
PolarDB MySQL引擎重磅功能及产品能力盛大发布 立即下载

相关镜像