Yarn 上的 Apache Flink - 保存点

Apache Flink on Yarn - savepoint

我们在 emr 上使用 yarn 来提交我们的 flink(flink 1.8.0) 作业。我们如何使用保存点完成优雅关闭。停止命令无法识别 -s 或 -p

Flink 1.8 不支持带保存点的优雅停止。这个特性是在 Flink 1.9 中加入的。使用 1.8 可以做到

./bin/flink cancel -s [targetDirectory] <jobID>

有关详细信息,请参阅 CLI documentation for version 1.8