Flink支持两种容错机制:Checkpoint和Savepoint。

Checkpoint是一种周期性的机制,用于在Flink Job执行过程中创建一些快照,以便在任务失败时能够恢复到先前的状态。Checkpoint可以设置间隔时间和最大并行度,可以保证精确一次语义。在每个Checkpoint的时候,Flink会将整个任务状态写入到分布式文件系统中。当任务失败时,Flink可以使用最近的Checkpoint来恢复任务状态。

Savepoint是一种手动触发的机制,它可以使Flink Job暂停并在某个时间点上创建快照。与Checkpoint不同,Savepoint可以在Job运行期间的任何时候手动触发,而不必等待周期性的Checkpoint。Savepoint允许用户在任何时候保存任务状态,以便在需要时能够恢复任务状态。Savepoint的使用需要手动触发,并且需要在Flink Job中显式指定。

Flink job级别的容错是什么?

原文地址: https://www.cveoy.top/t/topic/f6py 著作权归作者所有。请勿转载和采集!

免费AI点我,无需注册和登录