从所选源重新启动后如何恢复状态（不一定是最后一个检查点）

Question

我一直在尝试从之前的检查点重新启动我的 Apache Flink，但运气不佳。我已经将代码上传到 GitHub，这里是主要类： https://github.com/edu05/wordcount/blob/restart/src/main/java/edu/streaming/AppWithKafka.java

这是一个简单的字数统计程序，只是我希望程序在重新启动后继续使用它已经计算的字数。

我已经阅读了文档并尝试了一些东西，但一定是缺少一些愚蠢的东西，有人可以帮忙吗？

另外：最终目标是将 wordcount 程序的输出生成到压缩的 kafka 主题中，我将如何通过首先使用压缩的主题来加载应用程序的状态，在这种情况下，它既可以作为输出以及程序的检查点机制？

非常感谢

Answer 1

Flink 的检查点用于在失败后自动重启。如果要手动重新启动，请使用savepoint 或externalized checkpoint。

如果您已经尝试过，但仍然遇到问题，请提供有关您尝试过的更多详细信息。