You need to enable JavaScript to run this app.
优惠活动
大模型
产品
解决方案
定价
更多

如何在Flink standalone-job.sh中设置restoreMode为CLAIM模式?

问题解答

是的,-restoreMode(或--restoreMode)是flink run命令专属的提交参数,standalone-job.sh对应的入口类参数解析逻辑不包含该选项,因此直接添加会触发参数解析错误,即使启动成功也不会生效。

2. 如何通过standalone-job.sh实现CLAIM模式恢复savepoint?

可以通过指定Flink配置项的方式实现,有两种可选方案:

方案一:修改全局配置(适用于所有任务)

在Flink的conf/flink-conf.yaml中添加以下配置:

execution.savepoint.restore-mode: CLAIM

修改后重启standalone-job.sh启动的集群,所有任务都会默认使用CLAIM模式恢复savepoint。

方案二:启动命令中通过-D参数指定(仅当前任务生效)

直接在启动命令中添加配置参数,修改后的完整命令:

./bin/standalone-job.sh start-foreground --job-classname my.job.App -s s3://storage/savepoint-000000-a46bfd06daf8 -D execution.savepoint.restore-mode=CLAIM

这种方式无需修改全局配置,仅对本次启动的任务生效,灵活性更高。


内容的提问来源于stack exchange,提问作者Vin

相关产品推荐
方舟 Agent Plan

超全模态模型 × Harness 升级,最新支持 Deepseek-V4.1-Flash、GLM-5.3 系列、Doubao-Seedream-5.0-pro、Kimi-K3 (部分), 限时 9.9 元起

最近更新时间:2026.08.15 18:10:35