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/