Flink 故障恢复：如果无状态算子失败了怎么办

Question

我们知道，Flink 会定期为每个有状态的算子创建检查点，当崩溃发生时，它可以使用检查点来恢复系统。但是我找不到任何关于无状态算子在这些过程中的论文或文档——“检查点的创建”和“故障的恢复”。谢谢你的帮助。

Answer 1

无状态操作符没有状态，因此没有要检查点或恢复的内容，这就是为什么不在检查点创建或恢复的上下文中讨论它们的原因。