代码中没特别指定Serializer。都是默认的序列化。
在 2020-04-29 18:20:22,"Congxian Qiu" <qcx978132...@gmail.com> 写道:
>Hi
>从错误日志看,是 StateMigration 相关的问题。
>你需要确认下,你的代码中的 Serializer 和 savepoint 中 state 相关的 serializer
>是一样的或者是兼容的,你可以参考下这个文档[1]
>
>[1]
>https://ci.apache.org/projects/flink/flink-docs-release-1.10/dev/stream/state/schema_evolution.html
>
>Best,
>Congxian
>
>
>guanyq <dlgua...@163.com> 于2020年4月29日周三 下午6:09写道:
>
>>
>> 附件是代码和错误日志。目前不知道如何调查。麻烦帮忙看下 谢谢。

回复