apache-flink - 保存点与外部检查点

Question

1. 根据主题，我是否理解正确（来自 https://ci.apache.org/projects/flink/flink-docs-release-1.5/ops/state/checkpoints.html#difference-to-savepoints），唯一的功能区别（存储格式除外，并且保存点不能是增量的）是保存点状态支持重新缩放（stop-change_parallelism-start，对吗？）而检查点不支持？
2. 还有什么（文档说“重新缩放等功能”）保存点支持检查点不支持？
3. 拥有这两个如此相似但又复杂的实体看起来不是很奇怪吗？有合并它们的计划吗？
4. 是否有计划支持检查点状态+重新缩放（自动缩放功能可能需要）？
5. 如果我从外部检查点切换到自定义外部定期保存点服务，我会损失很多吗？

标签： apache-flinkflink-streaming

Answer 1

首先只是澄清最大的区别是它们使用不同的存储格式。检查点使用存储后端原生格式（例如 RockDB），而保存点使用 flink 原生格式。这种区分允许很少的用例，否则是不可能的。我认为这回答了第一点。

Ad.2 这就是说您只能使用保存点重新缩放，但例如需要检查点来执行本地恢复（在 1.5+ 中可用）。另一个重要的区别是您应该能够使用保存点切换状态后端，但您不能使用检查点进行切换（因为它们使用本机格式）

Ad.3 我认为通过上述解释，答案应该相当简单。这并不奇怪，也不认为有这样做的计划。

Ad.4 自动重新缩放肯定在路线图上，但不要认为有固定的时间表。

Ad.5 如果您完全禁用检查点，您将失去自动恢复。如果您只是从外部切换到 flink 托管检查点。你不应该松太多。