温馨提示:文本由机器自动转译,部分词句存在误差,以视频为准
00:00
刚才我们给大家讲了一下优雅的关闭啊,所谓的优雅关闭呢,就是说当我们想去关闭的时候,并不是真正的关闭,而是把我们当前的数据处理完之后才去关闭,而且这种关闭呢,它会导致我们所有的节点都同时会关闭,对不对,不是那种强制关闭啊,这个呢,我们给大家说了一下,跟人家演示了一下啊,那么接下来呢,我们再说一下,因为你停止了嘛,你把我们的这个数据给它停止之后,那如果再重新启动之后呢,这个时候就涉及到一个数据恢复的问题。所以啊,这个咱们给大家去介绍一下啊,咱们的这个数据的恢复,它其实啊是通过我们的环境流来做操作的,什么意思呢?大家可以看到我们的streaming contest,它其实我们在之前呢,是new出来的,但是它可以配置咱们的检查点,你配置检查点以后,它完全可以从检查点来恢复数据啊恢复数据好,大家可以看到我们这里面有个叫streaming contest,这个呢,我们给大家稍微的咱们说一下来关掉,嗯,来拷贝,拷贝以后呢,我们写上一个,咱们叫做零九啊,咱们叫做resume啊。
01:09
咱们来啊,咱们给它来恢恢复数据,那么这个恢复数据呢,把这个呢,我们就去掉了,其实我们都可以去掉啊,我想一想啊,咱们这个都去掉吧,还是不去掉呢?嗯,先不去掉了吧,把咱们这个去掉吧,啊来把咱们这个去掉啊OK。把咱们这个线程呢给它去掉,咱不要它了啊。好了,那么去掉以后,大家看一下,咱们这个时候呢,说了咱们想要恢复数据,所以点它有一个叫get active or create,那么这个时候呢,它里面可以设置一个检查点路径,就意味着你将之前的数据保存到检点当中,如果你不保存的话,那么我们再重新启动之后,前面的数据就丢失了,这个没问题吧,同学们这个能不能明白,因为你停止了我们的程序嘛,那么你现在数据如果不保存下来的话,我们数据是不是就丢失了,那么你光保存下来,如果你不能从这个保存数据恢复的话,是不是也不行?所以啊,咱们要从检查点来恢复数据,那如果万一恢复不到怎么办?诶,我要创建新的,所以呢,它有我们的第二个参数,第二个参数呢,就是如何来创建咱们的这个环境对象,所以咱们提示一下同学们,看它这边呢,就是创建咱们的对象啊,所以来咱们写上一个它,然后拿过来写个花括号,这个花括号当中我们就。
02:29
就直接啊,把咱们这个代码呢,原封不动,咱们拿过来啊,咱们拷贝,拷贝以后放过来,诶放到这边,放到这边以后把咱们SSSC放过来,嗯,就可以了,你放过来以后,这就是我们创建我们环境的对象,然后呢,给它来一个咱们叫SSC,等于它好了,然后呢,你再把这边拿过来,其实这就可以了啊,那么但是呢,有个问题就是我们需要的是把这个检查点给它配置好,咱们叫checkpoint,叫做CP对吧?所以啊,这都是连贯在一起的,你在做数据操作的过程当中,把它保存到检查点当中,然后呢,当你出现问题,再从检查点中恢复数据,那不就OK了吗?然后呢,再去启动,那么我们在这个位置大家可以看到它可以启动一个线程来完成我们的关闭操作,所以啊,这个跟咱们前面讲的就结合在一块儿了啊,所以咱们这个呢,其实跟优雅关闭是有一定关系的,它是用来恢复数据的啊同学们。
我来说两句