如何在Flink standalone-job.sh中设置restoreMode为CLAIM模式?
问题解答
1. -restoreMode参数是否仅支持flink run命令?
是的,-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
相关产品推荐
相关产品推荐

