Flink CDC中请问连接mariadb数据库的时候对于ddl变动一直出错要如何处理？
Flink CDC中请问连接mariadb数据库的时候对于ddl变动一直出现Dummy event replacing event type 160 that slave cannot handle要如何处理？
写回答
-
北京阿里云ACE会长在 Flink CDC 中，如果连接 MariaDB 数据库时对于 DDL 变动一直出错，可以尝试以下解决方案：
检查数据库配置：检查 MariaDB 数据库的配置是否正确，例如用户名、密码、数据库名称等。
检查 MariaDB 版本：检查 MariaDB 的版本是否支持 Flink CDC，建议使用 MariaDB 10.2.9 或更高版本。
检查数据库权限：检查连接 MariaDB 的用户是否具有操作数据库的权限，例如创建表、删除表等。
检查 Flink CDC 版本：检查 Flink CDC 的版本是否与 MariaDB 数据库版本兼容，建议使用最新版本的 Flink CDC。
检查 MariaDB 配置：检查 MariaDB 的配置是否正确，例如 binlog 格式、binlog-row-image 配置等。
检查 Flink CDC 配置：检查 Flink CDC 应用程序的配置是否正确，例如是否正确设置了数据库连接参数、表名称等。2023-07-29 18:41:14赞同 展开评论 打赏 -
存在即是合理这个问题可能是由于 Flink CDC 在同步 MariaDB 数据库时，无法识别到 DDL 变动导致的。建议解决方法：
检查 Flink CDC 的版本是否与 MariaDB 数据库的版本兼容。如果不兼容，请升级或降级 Flink CDC 或 MariaDB 数据库的版本。
检查 Flink CDC 的配置是否正确。特别是检查
debezium.mariadb.ddl.output.mode和debezium.mariadb.ddl.output.positions两个参数是否设置正确。如果以上方法都无法解决问题，可以尝试使用其他 CDC 连接器，例如 Debezium,它可能与您的 Flink 版本兼容性更好。
2023-07-25 16:17:20赞同 展开评论 打赏
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务，基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎，提高作业开发运维效率。
