Hi 我觉得这个不是root cause,实际上 transient ListState 是一种正确的用法,因为state应该是在函数open方法里面进行初始化,所以transient 修饰即可。
麻烦把这个list state的初始化以及使用方法的代码都贴出来吧。 祝好 唐云 ________________________________ From: Liu Rising <[email protected]> Sent: Thursday, September 3, 2020 12:26 To: [email protected] <[email protected]> Subject: Re: 从Savepoint/Checkpoint恢复时 keyedstate中部分数据无法被读取 Hi 找到原因了。 问题在于在定义ListState时使用了transient关键字,如下。 private transient ListState<ObjectNode> state; 去掉了transient之后,问题解决。 虽然不太清粗为何transient会造成这种情况。 -- Sent from: http://apache-flink.147419.n8.nabble.com/
