Hi 中锋 恐怕不能通过代码来回复savepoint,目前一共只有有两个地方可以传入savepoint path,分别是
1. CliFrontendParser#createSavepointRestoreSettings [1] 2. JarRunHandler#getSavepointRestoreSettings [2] 分别对应命令行,网页(REST)提交,没办法在代码里面进行恢复请求,其实我理解REST或者网页提交应该也满足你们的需求。 [1] https://github.com/apache/flink/blob/f400fbbe138696e82897941ee012f64c23f7dfcd/flink-clients/src/main/java/org/apache/flink/client/cli/CliFrontendParser.java#L434 [2] https://github.com/apache/flink/blob/f400fbbe138696e82897941ee012f64c23f7dfcd/flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/JarRunHandler.java#L111 祝好 唐云 ________________________________ From: 戴嘉诚 <a773807...@gmail.com> Sent: Friday, August 9, 2019 20:54 To: user-zh@flink.apache.org <user-zh@flink.apache.org> Subject: 答复: 恢复savepoint,除了命令行,能通过代码获取吗? 你好, 可以通过flink的restFul去调用保存savepoint 发件人: liu zhongfeng 发送时间: 2019年8月9日 20:28 收件人: user-zh@flink.apache.org 主题: 恢复savepoint,除了命令行,能通过代码获取吗? 如题,restore savepoint,除了run flink -s savepointpath之外,能通过代码恢复吗,因为公司集群没法输入命令行。如果可以的话,能给个小demo,或者API也可以 谢谢。 Best, Rio Liu, 刘中锋