Flink 的状态编程时限

This topic created in 2099 days ago, the information mentioned may be changed or developed.

Flink 的 ValueState 状态保存时限是当前还没有 checkpoint 的数据吗？实测当 checkpoint 时间到了，此时程序重启，那么 checkpoint 之前的数据是没有 state 的，怎么把之前的 state 也找出来，有人知道吗

1 replies • 2020-11-11 11:58:03 +08:00

FireCat

Nov 11, 2020

这种情况重启后的状态要重新计算的，数据都在 Kafka 里，会同时回滚。