Re: 从Savepoint/Checkpoint恢复时 keyedstate中部分数据无法被读取

Wed, 02 Sep 2020 19:10:18 -0700 

Hi
   按理说 checkpoint/savepoint 有的数据，正常恢复后是可以读取到的。
   1 正常从 checkpoint/savepoint 恢复了吗？
   2 获取 state 的时候，key 是同一个 key 吗？
Best,
Congxian


Liu Rising <stockholm...@gmail.com> 于2020年9月3日周四 上午9:28写道：

> 版本: 1.9
>
> 问题：
> 当从savepoint或者checkpoint恢复flink job时，发现部分keyedState中的数据丢失。
> 这里我们使用的是ListState，里面存储的是ObjectNode(Jackson DataBinding)类型的对象。
>
> 查log发现部分key的 listState.get() 返回空的iterator。
> 然而使用State Process API确认State的内容时， 发现上述这些key对应的数据是存在于State中的。
>
> 求问各位大佬这种情况是怎么回事？应该如何排查
> 谢谢
>
>
>
>
>
>
> --
> Sent from: http://apache-flink.147419.n8.nabble.com/

回复