温馨提示:文本由机器自动转译,部分词句存在误差,以视频为准
00:00
呃,那么接下来呢,我们要去做point或者check point,呃,那此时呢,我们要开启我们的checkpoint,所以呢,我们写一下1.1啊,开启CK。这边呢,我们可以因为点。Enable checkpointing。啊,Checkpoint,呃,那此时呢,我们假如说给他五秒钟做一次,但生产环境当中我们可以设置为分钟级别的,对吧?呃,我们这块当年做一个演示,所以呢,我的时间设置的很小啊,那接下来呢,我们还要配置在车销保险当中的一些其他的参数,比方说在这个当中我们给他设置一个超时时间。给他一个十秒钟的超时时间,同时我们在可以设置一些其他东西啊,当然这个呢,大家自己在生产环境当中也都能知道啊,是什么情况,我们可以去它的一个模式。啊,假如说我们希望它是一个精准一次性,那executive,嗯,那同时。
01:01
还有我们可以看到这个当中呢,可以重新设置它的一个开启的间隔时间,对不对?呃,然后还有在当中呢,我们可以设置两个内容的最小的间隔时间,或者说我们设置一下最大的。并发的一个车换,假如说我只允许一次,好,这是开启CK相关的一些内容,但是还有很多参数呢,大家之前学习弗link的时候也已经了解了,这块我就不多说了,只是为了完成我们的拆方就好了,对不对?那接下来还有在我们做拆方的样恢复或者S做恢复的时候,我们是不是可以开启我们的状态后端做一个修改。对吧,那是默认的,它是内存的,那我们希望看到这个效果,所以呢,我们用IDFS,那我们就。a.set我们的叫state back,然后呢,我们创建FS的一个step back啊,然后这个当中呢,它需要一个地址对吧?String类型就好了,那我们就写上HTFS括号。
02:01
我的地址呢是哈维8020,然后接下来呢,我们是CDC的一个test,对不对,好,那我们就专门给它起一个。创建一个目录,然后呢,是属于我们的check幻CK目啊,比方说我们就叫一个CK目录行,那到这个为止呢,我们的内容就准备好了,呃,之后呢,我们要扔到集群上去运行啊,所以呢,我们要做一个打包。然后呢,我们一般跳过测试,当然我们当前这个代码当中并没有什么测试,那我们直接打个包。那flag CDC这个内容呢,是社区去开发的。啊,所以呢,在官方的内容当中,它并没有我们的。加包,所以我们需要打一个全量包,也就是大家刚才在我看到我粘依赖的时候呢,发现最后呢,我们加了一个。
03:00
三的一个插件,它可以将我们的依赖打到我们的JA包当中,对吧?嗯,那其他的依赖呢,都是一些比较简单的,比方说flink Java,对吧,我们要走这个程序,以及flink streaming的一个javalink客户端,为了在本地可以运行哈杜的一个内容。啊,还有多客户端,因为我们要将数据呢保存到HDFS,当然这块我们本地并没有做测试,呃,那下来买S的驱动。嗯。我们最后呢,写弗Li的个代码,所以说呢,Table plan,我们给它拿进来以及。最核心的我们讲的就是当前CDC的一个联系,最后呢,我们需要自定义反学化器的时候呢,想想将数据转成一个接层格式,所以呢,我们导了一个法杰。好,那这个时候呢,我们只需要等着他打包完成,因为我们加了那个三的一个插件,所以它会打全量的依赖进去,我们稍微等一下。这边呢已经成功了,对吧,好,那此时呢,我们就打包完成了。
我来说两句