00:00
那这边呢,我们去做测试啊,那这边我先看一下,这边应该有一个他他呢我得给他干掉啊,啊杠阿尔法飞,这是我们之前做的测试啊,我接下来呢,把架包拖进来可以吧,好,那接下来呢,在这个把这个拖进来。哎,这个地方还是不行,那我们out加P啊,CD到OBD Mo到link stand劳了,哎,也就是说我们把东西呢,拖到这个目录,就当前刚才那个目录啊,行,那我们把它拖进来。嗯,那这边呢,L下就多了这么一个东西,那我把这个改个名字啊,这个太长了,对吧一下,嗯,MV叫君莫。那我们叫追梦,把后面这个东西的都给它干掉吧。就直接叫J末杠Li-CDC点加包对吧,简单一点啊行,那接下来我们就启动当前这个任务,启动当前任务那就B。
01:02
啊若对吧,运行好,那下来了杠M哈杜102冒号8081啊找manager对吧,然后杠C啊class,然后接下来呢,我们把这个CDC拷贝它的一个全类名对吧,右键啊copy reference,然后呢,把它放在这,接下来点杠我们的j more这个加对吧,我们正常的第一次运行嘛,它也没有什么checkpoint,也没有point,我们就直接这样去做一下就好了,行。呃,我们写的是初始化的,所以接下来呢,我们应该会在某一个task manager当中会看到我们这个信息被trademark,对吧?我们读的是这张表啊,呃,有11条数据,就是把之前的数据我都删掉了,对吧?还是这个最早的11条数据,等会呢,我们可以做一个测试啊。好,这边呢,已经submitted提交了,提交之后呢,我们就可以到这边来看一下,哎,运行了job有一个对吧?呃,由于我们设置的它的一个病度为一,所以它只要一个lo就行了,诶它在重启啊running。
02:11
他刚才好像在重启当中,对吧,好像有一点小小的问题啊,呃,那现在呢,是运行起来了,我们看一下结果,呃,那它这个manager那么多,我们可以看到它现在运营在哪啊,首先我们有六个lo,总的slo在这,那现在空闲的lo是221,那很明显是这台服务器。提供了一个slot对吧?啊提供了lo,所以呢很简单,这个呢是在102,那我们点进去,点进好以后呢,S TD out对吧,我们看一下它的输出就好了,输出来看一下这个里边是不是有这些数据对吧?好,那我们就看到这些数据就有了。啊,对了,同时连到最新的数据了,对吧?啊,这是最新的数据了,行,那接下来呢,我们做一个增删改,OK吧,新增一条来。
03:01
先新增一个12。然后呢,我们叫爱的硅谷。还有硅谷先保存,保存好以后我们还是到页面来看啊,刷新一下对吧,好,现在呢,又多了一条数据了,对吧,刚才是连接的这个地址,然后呢,又多了一条,多了一条呢,是12ID,硅谷没有问题啊,这是新增,然后呢我们修改,呃,给一个UR地址,URL地址呢,假如说我也搞成它啊,往那一放,对吧,保存这是改操作。啊,修改update好,那我们再刷新一下啊,这个是32行对吧,现在32行刷新变成33行了,33行呢,我们看一下它这个修改,它有before老的数据什么样子,然后呢,After新的数据又是什么样子,对吧?多了这个static before.JBD啊多了这条数据对吧?接下来我们删除一条,注意这个到33了,删除应该会是34行数据啊行,那我把这一行呢再删掉。再删掉对吧,刷新一下啊呃,那接下来到页面上面,我们刷新是不是34行数据就来了,对吧,它是一个删除操作啊,删除操作op呢是一个d delete op是一个delete对吧?好,那在这种情况下来说,我们就看到了,在集群当中,我们先测试这个任务是好的,对吧?那接下来比方说我要怪掉了,那刚才那个肖总说了,我们没有设置这个东西,我现在就康那就没效果了,开个换就没了,所以很简单,假如说现在呢,我要去手动做什么呢?做这个cons,哎,你要注意,如果说你没有配置那个参数,在手动CR之前,我们一定要干什么去做一次save point。
04:46
对吧?啊,那我们就演示一下这种方案,刚才项总说到的就是这个参数我们没有设置对吧?啊,它并不是必须配的好,那我们CD到这个。OB Mo啊到Li stand along啊,Stand along,然后接下来呢,我们去开启当前这个任务的一个save point啊B,那link,然后point。
05:12
So point对吧,命令也要记得啊,然后接下来是不是任务ID啊,指定一个任务ID,最后呢是地址,任务ID呢,我们去拿一下在这边。点击诶这边呢,就有一个任务ID来把它考到C复制上啊,这是当年任务的,而且弗林CDC这个名字呢,是来自于这啊。任务的名字来自于这这要注意一下,我们自己传进去的,对吧,当然你不传,不传的话,它就叫Li steming job,大家都是统一的名字了,以后不好区分对吧?好,那我把这个命令,呃,把这个招牌ID拿到,接下来我们要给个地址,给个地址呢,这样我就不自己敲了,我直接把这个拿过来。拿好以后,我叫save point。呃,或者叫SV吧,V。
06:02
啊就行了,对吧,So point,我们做这个事情行,那我们运行一下。好,这边呢,已经做好了。已经做好了,大家看到吧,对吧,而且它告诉我们可以重启我们的任务,从当前这个point啊,With the rock启动命令,注意这时候启动命令跟刚才就不一样了,对吧?啊地址呢,是这个行,那现在呢,我就可以把任务关掉了,因为我们已经有了point,同时可以给大家看一下啊这边哈杜甫1029870。呃,进到我们的文件系统。然后呢,我们刚才是这个追梦210325对吧,这边有两个,一个CK一个SV啊,那CK当中看。这个数据这个是之前坏掉的一次啊,它中间应该重启了一次,那一次可能遇到什么异常了,我记得大家还记得有中间我们任务有重启吗?浅蓝色的重启对吧?它应该划掉的,这个就不用管了啊,那这个呢,我们可以刷新诶63了,每五秒做一次,对吧,这个就不用管了,好那还有一个,这个是c point c point当中呢,有一个地址,诶这里边呢,也有保留的状态信息,对吧,因为。
07:16
我们要想实现读取0LOG断点续传的功能,那肯定要保留这个信息啊,一定要有这样的东西对吧?好,那这个呢,我们就不用管了,接下来呢,我就把这个任务cancel掉。OK啊,取消当前的这个任务。让他把这个任务呢给他干掉啊,大家要注意一下,刚才我们数据已经是这个里用的,这个里边为了防止他再用它啊,我们把这个呢保留一下,刚才数据呢是到34行。对吧,如果还用的是它,那我们应该从三十五行开始,而且呢,断点续传对吧,应该接下来从三十五行开始啊呃,那这个时候呢,我们怎么做测试呢?我在任务挂掉之后,现在任务是挂掉的,对吧,我在这个时候再去新增一个数据12。
08:09
呃,假如说为了跟刚才不冲突啊,不叫13对吧,13,然后呢,上海校区好先新增一条,然后A我修改一条,再把这个数据删掉一条。对吧,也就是说在我任务挂掉之后,我做了增删改三件事情。啊,三件事情,如果它能够断点续传的话。那么他只会打印这三条数据,大家想一下有没有问题?就是你在测之前一定要想好你的测试逻辑啊。有没有问题?如果能够断点续传,是不是应该只打印这三条数据,关于13ID为13的这三条数据啊,新增修改和删除。
09:00
OK吗?对的,这个肯定没有问题。对吧,好,那接下来呢,我们去重启这个任务啊,注意这边就挂掉了,对吧,这是客户端,好,那重启的时候我能这样重启吗?大家想一下。肯定不能,我如果直接敲回车,没有任何意义。对吧,因为你没有从point,也没有从checkpoint当中去做恢复,所以这个是无效的,这个肯定无效,对吧,所以我们得加一个叫杠S。杠S指定checkpoint或者叫point对吧,那接下来呢,地址我从这拿一下就好了,我也不去点拿了,这边已经告诉我们了,对吧,方便啊来好,那我们。启动。啊,我们重新启动一下走。我这个截图是防止他又用到哈102这个机器啊,如果用103104的话没有问题,我们只看三条就行了,如果用102他打印一堆,所以我要留一点上一次打印的位置在哪对吧?好,那这个时候启动了,我们再看一下这一次运行任务,哎,运行当中对吧,然后我们看一下他用的哪个,哎,你看果不其然用的102吧,所以那接下来我们应该从。
10:26
35这个位置开始看吧,对吧,好点进来IC out,那我们看35。好,35呢是一个连接信息。啊,上一次断掉的位置883啊,对吧,他断掉的从这个位置断掉了,他直接连进来了,他把这个883呢,提交到拆换的好那家来,这个是三十七三十八三十九三条数据没问题,哎,数据量对了,那看一下啊在so对高那ID13这个应该是一个新增,我们先增了一个上海,然后做了一个修改,对吧,第二做了一个修改,所以before是这个数据after。
11:07
是它A,最后呢,我又把这条数据删除掉了,所以它只有before没有after,同时我们也可以看到op是D,那这个三条数据可以从op来看啊呃,这个地方op在c create新增对吧,那第二个。Update更新,第三个delete删除对吧,那其实在我们Li CC里面是可以做到断点续传的,只不过说这个时候要依赖于C的,或者说。拆语要依赖于这个才可以,对吧,才可以做到这个断点续传啊,那同时呢,它还还能初始化数据,也就是说读全量数据,同时在增量读取,这个都是可以的啊,这都可以的,那也就是说它有这个功能,我们要去演示一下啊行,这个呢是我们刚才留的一个证据,从三十五行开始看,对吧,三十五行呢是一个日志信息。
12:01
啊,这个两个信息啊,连接到blog上一次的位置,对吧,之后呢,是打印我们。未消费到的数据啊,行,这个呢,就测试完成了。
我来说两句