Flink CDC 设置了includeSchemaChanges 这个以后，需要怎么处理啊?
Flink CDC 设置了includeSchemaChanges 这个以后，修改表结构 会抛异常，
Row arity of record (5) does not match this serializer's field length (7).
需要怎么处理啊?
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
-
当Flink CDC设置了includeSchemaChanges参数后，如果修改表结构导致字段数量发生变化，就会出现这个异常。为了解决这个问题，你可以尝试以下方法：
在Flink CDC的配置文件中，将includeSchemaChanges参数设置为false。这样，Flink CDC就不会记录表结构的变更，从而避免了异常的发生。
如果你确实需要记录表结构的变更，可以考虑使用其他支持表结构变更的CDC连接器，例如Debezium。但是请注意，这可能需要对现有的应用程序进行一些调整。
如果以上方法都无法解决问题，你可以考虑在修改表结构之前，先将表结构备份，然后在修改完成后恢复备份。这样可以避免因表结构变更导致的异常。
2023-10-23 16:42:45赞同 展开评论
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务，基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎，提高作业开发运维效率。