使用lombok生成的pojo对象是否支持State Schema Evolution

flink版本：1.9.0 问题：使用lombok生成的pojo对象，在数据流进行传输，中途终止任务做savepoint，state中保存应该都是这个对象； 从savepoint重启任务后，报这个error：StateMigrationException: The new state serializer cannot be incompatible. ... Heap state backend -- Best, Howie

Re:使用lombok生成的pojo对象是否支持State Schema Evolution

Hi，请问下是修改了作业的逻辑之后，根据savepoint重启吗？如果是这样，是状态不兼容的原因 在 2022-06-29 17:57:54，"Howie Yang" 写道： >flink版本：1.9.0 > >问题：使用lombok生成的pojo对象，在数据流进行传输，中途终止任务做savepoint，state中保存应该都是这个对象； >从savepoint重启任务后，报这个error：StateMigrationException: The new state serializer >cannot be incompatible. ... Heap state backend >

Re:Re:使用lombok生成的pojo对象是否支持State Schema Evolution

Hi，Xuyang 修改了作业的逻辑，但可能核心问题还是我修改了数据流中的pojo对象（新增了字段），最终导致了这个问题的出现 -- Best, Howie 在 2022-06-29 22:52:04，"Xuyang" 写道： >Hi，请问下是修改了作业的逻辑之后，根据savepoint重启吗？如果是这样，是状态不兼容的原因 >在 2022-06-29 17:57:54，"Howie Yang" 写道： >>flink版本：1.9.0 >> >>问题：使用lombok生成的pojo对象，在数据流进行传输，中途终止任务做savepoint，state中保存应该都是这个对