Hi,Xuyang
修改了作业的逻辑,但可能核心问题还是我修改了数据流中的pojo对象(新增了字段),最终导致了这个问题的出现




--

Best,
Howie





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

回复