flinkcheckpoint与savepoint
时间: 2023-09-30 13:12:06 浏览: 78
SavePoint.java
Flink 中的 Checkpoint 是一种机制,用于在运行中保存应用程序的状态。Checkpoint 可以保证在发生故障时能够恢复应用程序的状态,从而实现应用程序的容错性。
Flink 中的 Savepoint 是 Checkpoint 的一种特殊类型,它是一种手动触发的 Checkpoint。Savepoint 可以在应用程序运行期间手动创建,并且可以在重新启动应用程序时用作恢复点。
Checkpoint 通常是自动触发的,并且会定期保存应用程序状态。Savepoint 通常是手动触发的,并且是一次性的。Savepoint 可以帮助您在运行中修改应用程序,并将更改应用于新的执行环境,从而使应用程序更具灵活性。
阅读全文