未分类
Posted by

flink-31 容错机制

在flink中有一套完整的容错机制来保证故障后的恢复,其中最重要的就是检查点 检查点 在流处理中可以用存档读档的思路,将之前某个时间点所有的状态保存下来,这份存档就是所谓的检查点(checkpoint) 遇到故障重启的时候,我们可以从检查点中读...