在 Yarn 集群上提交 Flink 作业以从上一个保存点恢复其状态

【问题标题】：Submit Flink Job on Yarn cluster to restores its state from it's last savepoint在 Yarn 集群上提交 Flink 作业以从上一个保存点恢复其状态
【发布时间】：2018-06-01 23:54:45
【问题描述】：

我在 Yarn 集群中运行这些 Flink 作业。当 flink 作业失败或我重新启动它时，我希望 Flink 作业使用在它重新启动之前创建的保存点。如何使用此保存点重新启动 Flink 作业。我正在使用 Flink 1.4.2。

【问题讨论】：

标签： hadoop-yarn apache-flink flink-streaming flink-sql

【解决方案1】：

要从保存点恢复，您必须调用 bin/flink run -s :savepointPath [:runArgs]，其中 runArgs 包含作业 jar。

【讨论】：

如果我直接通过 CLI 执行此操作，则效果很好。我正在使用 Yarn 客户端提交作业。