开发者社区> 问答> 正文

一个FLINK程序有多个检查点,恢复的时候如何从多个检查点恢复?

环境说明:
flink 1.5
用api写的FINK SQL
检查点是写到HDFS的

这个程序里面有多个SINK输出,我看对应的检查点有多个,
这种情况下如果程序失败了,如何从多个检查点恢复数据?

这是我一个检查点恢复的语句:
bin/flink run-application -t yarn-application -d -Dtaskmanager.memory.process.size=2048M -Dtaskmanager.numberOfTaskSlots=1 -p 3 -c com.dfsk.atp.vat.faultdetection.EolTestReport ./projects/atp-vat-flink-data-1.0-SNAPSHOT.jar --mode dev -s hdfs://nameservice:8020/user/hdfs/flink/eoltestreport_status/f131a1b66de10b5b34680c4b64d37868/chk-11/_metadata

不知道多个检查点的情况下如何恢复,语句怎么写?

展开
收起
游客fuzojzpl5x2bu 2023-08-10 10:56:20 121 0
1 条回答
写回答
取消 提交回答
  • 发表文章、提出问题、分享经验、结交志同道合的朋友

    你好,在 Flink 中,如果程序失败了,可以使用检查点来恢复数据。在 Flink 1.5 中,可以使用以下命令来恢复多个检查点:

    bin/flink run-application -t yarn-application -d -Dtaskmanager.memory.process.size=2048M -Dtaskmanager.numberOfTaskSlots=1 -p 3 -c com.dfsk.atp.vat.faultdetection.EolTestReport ./projects/atp-vat-flink-data-1.0-SNAPSHOT.jar --mode dev -s hdfs://nameservice:8020/user/hdfs/flink/eoltestreport_status/f131a1b66de10b5b34680c4b64d37868/chk-11/_metadata -s hdfs://nameservice:8020/user/hdfs/flink/eoltestreport_status/f131a1b66de10b5b34680c4b64d37868/chk-12/_metadata -s hdfs://nameservice:8020/user/hdfs/flink/eoltestreport_status/f131a1b66de10b5b34680c4b64d37868/chk-13/_metadata
    

    这个命令可以恢复多个检查点,以便在程序失败时恢复数据。在这个命令中,需要指定每个检查点的路径,以便 Flink 能够正确地恢复数据。

    2023-08-10 14:16:00
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Flink CDC Meetup PPT - 龚中强 立即下载
Flink CDC Meetup PPT - 王赫 立即下载
Flink CDC Meetup PPT - 覃立辉 立即下载