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