然后我们再来细看一下:
flink是怎么实现,检查点的保存的呢?
我们有两种方式,第一种简单的方式,我要想保存一个检查点的时候,我等某个数据处理完,然后
把这个处理完的数据保存成一个检查点,这个数据处理的时候,我要暂停其他的所有的应用,等待
这个数据处理完,这个方式,可以看到简单,但是效率很低.
在flink中有一种,可以看到叫做基于Chandy-Lamport算法的,分布式快照,这个就可以
让taskmanager不停止工作的同时来保存检查点.并且可以保证一致性.
我们看一下他是怎么做的,这里可以举个例子.
首先对于,我们排集体照来说,首先摄影师,要提醒大家,每个人都放下手头的工作,然后
整理好以后,然后再说茄子,然后再拍照很麻烦对吧,拍的时候,需要每个人都停下手头的
工作.然后再拍照实际上就是上面我们说的,先暂停所有应用,然后再进行存快照,效率低
对吧.
那么我们还可以怎
