如何用检查点改变星火流应用程序？

Question

请考虑以下情况：

• 通过火花流创建初始管道
• 启用检查点
• 运行应用程序一段时间
• 停止流应用
• 对管道进行了微小的更改，例如业务逻辑保持不变，但做了一些重构、重命名、类移动等。
• 重新启动流应用程序
• 获取一个异常，因为存储在检查点目录中的管道在类级别上与新的级别不同。

处理这种情况的最佳做法是什么？如何在启用检查点的情况下无缝升级流应用程序？流应用程序版本控制的最佳实践是什么？

Answer 1

tl;dr检查点是用于恢复情况，而不是用于升级。

来自关于检查点的正式文档

流应用程序必须24/7操作，因此必须能够抵御与应用程序逻辑无关的故障(例如，系统故障、JVM崩溃等)。要做到这一点，星火流需要检查足够的信息到一个容错存储系统，以便它可以从故障中恢复。

因此，要回答有关使用检查点(用于容错)和更改应用程序代码的问题，您不应该期望它会工作，因为它与设计背道而驰。