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 <[email protected]> 于2020年4月29日周三 下午6:09写道： > > 附件是代码和错误日志。目前不知道如何调查。麻烦帮忙看下 谢谢。
