Hi

我觉得这个不是root cause,实际上 transient ListState 
是一种正确的用法,因为state应该是在函数open方法里面进行初始化,所以transient 修饰即可。

麻烦把这个list state的初始化以及使用方法的代码都贴出来吧。

祝好
唐云
________________________________
From: Liu Rising <stockholm...@gmail.com>
Sent: Thursday, September 3, 2020 12:26
To: user-zh@flink.apache.org <user-zh@flink.apache.org>
Subject: Re: 从Savepoint/Checkpoint恢复时 keyedstate中部分数据无法被读取

Hi

找到原因了。

问题在于在定义ListState时使用了transient关键字,如下。
 private transient ListState<ObjectNode> state;

去掉了transient之后,问题解决。
虽然不太清粗为何transient会造成这种情况。



--
Sent from: http://apache-flink.147419.n8.nabble.com/

回复