新的状态序列化程序不能与Apche Flink SQL中的旧状态序列化程序不兼容

vmjh9lq9 于 2023-10-14 发布在 Apache

关注(0)|答案(1)|浏览(254)

我使用Kafka从Flink Datastream中阅读数据（从多个流中阅读），然后我使用flink SQL将这些流转换为临时视图并执行连接操作。对于连接操作，我也使用Flink SQL。我面临的问题是，当我在flink sql查询中添加新字段，然后尝试迁移保存点时，我遇到了这个错误：

Caused by: org.apache.flink.util.StateMigrationException: The new state serializer (org.apache.flink.api.common.typeutils.base.MapSerializer@58eac6c9) must not be incompatible with the old state serializer (org.apache.flink.api.common.typeutils.base.MapSerializer@a56de33a).

注意：当我检查时，这个错误是在我更改查询而不是数据流的pojo时出现的。

apache-flink

来源：https://stackoverflow.com/questions/77265753/the-new-state-serializer-must-not-be-incompatible-with-the-old-state-serializer