您好，我的版本是 1.14.3的，运行的逻辑就是使用状态存放数据，然后设置了ttl，时间是一个小时。新的作业启动后，如果不是基于之前的检查点恢复，那应该不会和之前的作业还有任何关联吧，很奇怪的点就是新的作业，会报这个错误，我在本地复现了一下，是旧的作业不设置ttl，然后新的作业设置ttl，以就作业的ck去恢复，报了这个错误，但是我的是全新的作业启动。 感谢您的回复，谢谢。
| | Jason_H | | hyb_he...@163.com | ---- 回复的原邮件 ---- | 发件人 | <zhanghao.c...@outlook.com> | | 发送日期 | 2022年8月19日 18:59 | | 收件人 | flink中文邮件组<user-zh@flink.apache.org> | | 主题 | Re: flink自动重启出错 | 能提供下你用的是什么 Flink 版本，运行的什么样的作业逻辑吗？老版本有发现过因为 state comparator 实现问题的导致的类似问题： https://issues.apache.org/jira/browse/FLINK-18452，1.12 中修复了。 新的作业如果开了 cp，全新启动后因为某些原因挂了也会从 cp 恢复，就能触发此类问题了 Best, Zhanghao Chen ________________________________ From: Jason_H <hyb_he...@163.com> Sent: Friday, August 19, 2022 11:52 To: flink中文邮件组 <user-zh@flink.apache.org> Subject: flink自动重启出错 cause by: java.lang.RuntimeException: Error while getting state org.apache.flink.util.StateMigrationException: For heap backends, the new state serializer must not be incompatible with the old state serializer 大家好，我最近遇到一个很奇怪的问题，我的作业自动重启的时候报这个错，我上网查了一下，说是状态不兼容，但是我的作业都是新的作业启动的，没有根据之前的ck恢复，然后跑一段时间就报这个错，它是自动重启的时候，就报这个错了，这个有遇到过吗？有没有什么解决办法？ 强调：作业是新的，没有基于之前的作业的ck进行重启。 | | Jason_H | | hyb_he...@163.com |
