我想在 Flink 中加载最新的检查点，但事实并非如此。我编写了一个字数统计应用程序，旨在重新启动后从中断的地方恢复计数。我正在从我的 IDE 运行它，所以我没有启动 Flink 集群。
这是我写的代码 https://github.com/edu05/wordcount/tree/simple这受到 Flink 创建者提供的关于检查点的示例的启发......https://github.com/streaming-with-flink/examples-scala
我错过了什么？如何避免重新打印一些字数？我在 Apache Flink 上的 Stackoverflow 中没有看到很多贡献者，还有另一个更合适的论坛吗？
默认情况下不保留检查点，仅用于从故障中恢复作业。
如果需要从保留的检查点启动作业，则必须手动执行此操作，就像从保存点一样，按以下方式
：$ bin/flink run -s :checkpointMetaDataPath [:runArgs]