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

回复