这是一个创建于 1557 天前的主题，其中的信息可能已经有所发展或是发生改变。
Flink 的 ValueState 状态保存时限是当前还没有 checkpoint 的数据吗？ 实测当 checkpoint 时间到了，此时程序重启，那么 checkpoint 之前的数据是没有 state 的，怎么把之前的 state 也找出来，有人知道吗
1 条回复 • 2020-11-11 11:58:03 +08:00
 |
1
FireCat 2020-11-11 11:58:03 +08:00
这种情况重启后的状态要重新计算的，数据都在 Kafka 里，会同时回滚。
|
Select Language