无法获取检查点以在Flink中加载

Question

我希望在Flink中加载最新的检查点，但它不是。我已经编写了一个字数统计应用程序，它的目的是在重启后重新开始计数。我从我的IDE运行它，所以我不会启动一个Flink集群。

这是我写的https://github.com/edu05/wordcount/tree/simple代码，它的灵感来自于Flink创建者提供的检查点示例……https://github.com/streaming-with-flink/examples-scala

我遗漏了什么？我怎样才能避免重新打印一些字数？我在Apache Flink上的Stackoverflow中看不到很多贡献者，有没有其他更合适的论坛？

Answer 1

默认情况下，不保留检查点，并且检查点仅用于从失败中恢复作业。

如果需要从保留的检查点启动作业，则必须通过以下方式手动执行，就像从保存点启动一样：

$ bin/flink run -s :checkpointMetaDataPath [:runArgs]