You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by Howie Yang <ha...@126.com> on 2022/06/29 09:57:54 UTC
使用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:Re:使用lombok生成的pojo对象是否支持State Schema Evolution
Posted by Howie Yang <ha...@126.com>.
Hi，Xuyang
修改了作业的逻辑，但可能核心问题还是我修改了数据流中的pojo对象（新增了字段），最终导致了这个问题的出现
--
Best,
Howie
在 2022-06-29 22:52:04，"Xuyang" <xy...@163.com> 写道：
>Hi，请问下是修改了作业的逻辑之后，根据savepoint重启吗？如果是这样，是状态不兼容的原因
>在 2022-06-29 17:57:54，"Howie Yang" <ha...@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
Re:使用lombok生成的pojo对象是否支持State Schema Evolution
Posted by Xuyang <xy...@163.com>.
Hi，请问下是修改了作业的逻辑之后，根据savepoint重启吗？如果是这样，是状态不兼容的原因
在 2022-06-29 17:57:54，"Howie Yang" <ha...@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