Flink作业，增加一个source和sink，启动抛异常，为什么？
Flink作业，增加一个source和sink，启动抛异常，为什么？
Caused by: org.apache.flink.util.StateMigrationException: The new key serializer (org.apache.flink.table.runtime.typeutils.coded.CodedRowSerializer@6924d8a3) must be compatible with the previous key serializer (org.apache.flink.table.runtime.typeutils.coded.CodedRowSerializer@174eece3).这个source和sink独立一个作业就可以顺利跑。
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
-
北京阿里云ACE会长
新的键序列化器（org.apache.flink.table.runtime.typeutils.coded.CodedRowSerializer@6924d8a3）必须与之前的键序列化器（org.apache.flink.table.runtime.typeutils.coded.CodedRowSerializer@174eece3）兼容。这意味着新的键序列化器需要具有与之前的键序列化器相同的序列化和反序列化规则。
解决这个问题的方法是确保新的键序列化器与之前的键序列化器兼容。您可以尝试以下方法：
确保Flink作业的代码和依赖项是一致的：确保源代码和依赖项的版本与之前的版本相同。不同版本的代码和依赖项可能会导致键序列化器不兼容。
显式指定键序列化器：在源代码中显式指定键序列化器，确保新的键序列化器与之前的键序列化器一致。您可以使用setKeySerializer()方法来设置键序列化器。
清除作业状态：如果您不需要保留之前的作业状态，可以尝试清除作业状态并重新启动作业。在启动作业之前，可以通过ExecutionConfig#disableForceKryo()方法禁用强制使用Kryo序列化器，以避免键序列化器不兼容的问题。
2023-08-08 18:17:52赞同 展开评论
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务，基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎，提高作业开发运维效率。