00:00
接下来我们来了解一下,呃,String上面怎么来部署一个flink circle的应用啊,也就是说我们只要专注于写circle,然后在页面上点击提交,这个flink程序就能够跑起来啊。来,我们直接来操作啊,点击这个string,差页面有一个应用application,同样点击加号。在这里呢,部署模式,开发模式,我们选择circle就不是写代码了,对吧,然后选择执行模式啊,其实就是flink的部署啊,提交模式,那我们比如说还选择一个雅安application啊,那还是一样可以选择版本啊,版本完事之后下面就写什么呢写了。对吧,那比如说我们以这个为例啊。创建两个外表,第一个呢是卡,我从卡数据,然后插入print这个连接器。
01:02
这个其实没有什么意义吧,这个就是做测试的时候啊,我们把它插入print这张表做一个输出展示。这是circle的一个用法啊。然后呢,你看呃,插入这个T2对吧,插卡不卡,插入到T2,说白了就是读取卡不卡数据打印出来,那这个东西呢,来我直接拷过来。多个circle口之间就是用分号啊,去做一个区分就可以了。那么这边要修改一下啊呃,Idts VC啊,卡普卡T1啊,接下来是一个什么卡普卡的地址,我改一下啊,我是哈杜19092。啊,这个这个写作啊,不是二九啊九二。这个哈杜二啊哈杜三。然后呢,消费者组ID对吧,自己命名啊,启动模式我从最新开始消费格式呢,呃,我指定为CSV好就没了。
02:09
再往下呢。我们是不是得导入一些依赖,什么依赖呢?就除了flink本身自带的依赖之外,呃,额外的依赖,就比如说我们是不是用到卡夫卡呀,那这个时候是不是得。添加一个卡夫卡连接器这么一个依赖是吧,那什么叫自带依赖呢?啊,比如说我们进入到flink1.13.6对吧,进来之后是不是有个立本目录啊,立本目录这些就是自带的依赖。有卡不卡连接器吗?没有啊。那这个时候我们可以选择第一种方式啊,直接导包。直接指定这个依赖啊,以键的格式这么来指定,或者说呢,你把这个连接器的依赖下载下来,是不是一个架包对吧?那你用上传这个连接器架包的方式也可以啊,那对哪一种比较方便,肯定是这个方便让它自动下载依赖对不对啊,就没必要自己再去上传了啊好。
03:14
再往下。这边可以选择应用的一个配置。那这个是应用名称。我写一下啊,比如说叫flink circle DEMO啊,这个一样的依赖加载方式还是parent first,并行动还曹树。这些配置是不是跟刚才一模一样啊,那我就不再讲了,都一样啊。你看现在是不是很方便勾勾选选。选的模式,选的版本写的circle。呃,需要的依赖就完事了,其他的是一些提交参数。一提交,那这个circle任务就添加完成了。接下来还是老规矩啊,是不是先点击这个,这个是什么启动应用。
04:05
啊。现在是启动中对吧,我们可以查看这个详细信息。他要完成三步。要先进行be的啊。然后解决妹的依赖,在之后呢,他会帮我们上传需要的价包,Application模式,是不是得上传一些价包啊啊好,可以看到三步都完成了,完成之后这个按钮就变了。就变成了可以什么呢?启动start啊,开呃提交嘛,大家可以理解为flink run啊,那个命令好一点。Point不要啊,我这边不用,然后点应用就行对吧,但是我卡不卡还没启动啊呃,我先起个组keep。再启动一下卡不卡。
05:10
看一眼。卡不卡好,接下来我们用控制台的生产者往这个topic发送消息啊,这个topic我还没有,嗯。叫什么来着?啊,我们刚才写的是什么,Topic是T1对吧。T1。好。那已经有了之后,我来启动应用。不要。应用。正在启动中。这里可以查看详细的信息。
06:03
你看内存使用量就出来了啊,执行中的作业啊。这个按钮同时变成了什么stop,停止应用对吧?啊跟刚才都一样,我们点这个小眼睛啊,看一下信息。那同样你可以点web UI啊。也可以看查看你之前写的这个circle是什么东内容。再往后看,Backup。对吧,在这里。还有一个日志,你也可以通过这里直接点过去啊来,比如说。看一下日志一点。是不是跳到flink web UI来了?那接下来操作就是大家最熟悉的,那接下来我们验证一下呗,呃验证什么呢?呃,点task manage对吧,它的一个输出s t out。那这边是一个字符串一一啊这样吧,CSV格式啊回车。
07:07
那在这里我们刷新,你看数据读取到了吧。刷新啊,你看这些都是通的吧,啊,而且作业名称也是按照我们指定的作业名称来的。这个呢,就是通过circle啊的方式来部署,那么大家以前我们写代码要怎么写,这个我们如果是代码是不是要首先要创建环境对吧,Table。Stream table environment,然后呢,再点一个呃,烟v table烟v.circle然后你是不是在里面再写一个字符串呢,去拼接啊是吧,就很多加号拼接起来的,对不对啊,那同样这种方式来写的话,是不是还得打打成然后再去提交。那还有一种使用方式,是不是flink自带的circle client客户端呢啊?
08:06
是不是直接在里面去写circle口一样的,那现在我们就变成什么。我环境什么都不用管了,我直接在这里应用,然后点击那个一个添加,把circle写进去,依赖放进去,参数指定一点提交就可以了,这样是不是可以大大提高我们的开发效率是吧?哎,这个呢不是。这差给我们带来的便利。
我来说两句