Flink checkpoint恢复疑问

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

Flink checkpoint恢复疑问

flink2021
请问下,如果我代码逻辑有变动了,可以从历史的checkpoint恢复吗?我试了下,从历史的checkpoints恢复的话,并没有执行我的修改后的逻辑,例如原来逻辑是
where flag=1 改为:where flag>1 ,从9点30的checkpoint :chk100 恢复,是不是 where flag>1
的逻辑只会对9点30后后的数据生效呢?



--
Sent from: http://apache-flink.147419.n8.nabble.com/