Apache Flink 中文用户邮件列表
Search
everywhere
only in this topic
Advanced Search
Flink checkpoint恢复疑问
Classic
List
Threaded
♦
♦
Locked
1 message
flink2021
Reply
|
Threaded
Open this post in threaded view
♦
♦
|
Flink checkpoint恢复疑问
请问下,如果我代码逻辑有变动了,可以从历史的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/
Free forum by Nabble
Edit this page