00:00
好,那么接下来呢,咱们首先来看一下提交流程,那咱们这边呢,主要以雅安的一个破旧模式为例,为什么呢?因为咱们在生产环境上啊,而且官方也建议基于雅安的一个特救本模式去做一个提交啊,所以咱们重点就放在这里啊。那首先我们讲这个,我们先来想一想。关于这个咱们是什么特点啊。一个救了一个集群,对吧,而且事先不用启动集群吧,只有在咱们提交的时候,雅安才会去帮我们启动一个集群,是这样子的,对吧?好,那它有哪些主要的进程呢。Java manager task manager对吧,还有一个客户端相关的对吧,但是他具体的名字在每个模式下面是不一样的,那我们首先呢,来熟悉一下他的名字啊。
01:02
呃,那比如说我在这边执行一个提交啊,那这边呢,我的雅恩跟那个HDFS是已经提起来了啊,那现在我是来到一个呃,解压完的啊,没有做任何配置。那接下来你看。比如说我这边做一个提交,我再拷贝一个啊,方便咱们查看啊,你看这个命令是Li脚本跟上一个执行的动作right对吧?哎,然后杠T指定一个模式,后面呢,是不是一个架包的路径啊,那有的同学可能有疑问,我为什么没有杠C啊啊这个这个是flink提供的示例代码啊,你不指定它里面也能找到,它只有一个入口,好吧啊。好。那这边呢,来,我回车。啊,等它启动啊,来咱们在这边看。进程啊,那首先我们能看到现在起了一个什么。
02:01
这是客户端相关的对吧,Cens好再看。正在部署对吧,还在部署啊。好了,已经提交上去,来,我们这时候再看一下进程。那么这一块咱们能看到一个啥。是不是一个雅安job是吧?Class entry point对吧?哎,这个就是咱们所谓的job manager进程在per job模式下的名称,好吧,哎,这个名字大家也不用去纠结,那我把这几个名字给大家考一下啊。啊,喝酒。那首先有一个客户端对吧,呃,还有一个这个。
03:02
啊,这个是没有正常启动啊,连接拒绝,因为我什么。没有起那个NC对吧。啊,我再我们再重新瞅一眼啊。好,已经提交上去。那这边讲道理应该会有一个什么呢?啊,当然这个任务没有正常启动起来,那咱们也不浪费时间了,我直接告诉大家吧,Task runner是吧,这个是什么?Task manager运行的那个进程对吧,那这边呢,可以给大家做一个介绍啊讲解,可能有些同学以前看到不是这样的,它叫什么。它叫task manager runner啊,这个是有历史原因的,就是因为它版本更新过程中啊,以前叫这个,后来呢,又做了一个新的叫这个,它俩的功能基本一样啊,那么可能不同的模式,它进程的名称不一样,这个大家仅注意了解就行了,对吧,比如说ste。
04:19
啊,他叫这个,那咱们大体呢,就了解到有三大进程,客户端还有。Job manager task manager相关的对吧?好,那咱们程序的入口在哪里啊?你看咱们执行了一个什么命令啊,是flink脚本呢,还给了一个run对吧?诶好,那咱们接下来只需要怎么样分析这个脚本就行了,那我们进到并目录下面啊,打开flink这个脚本啊。哎,我把行号打印出来,那么看到这个呢,大家可能啊。
05:02
一大头看着晕晕乎乎的对吧?哎,不要紧,前面呢,一般都是一些什么呀,是不是一些参数解析啊,环境啊,配置啊等等对吧,那它核心执行的语句在哪里。是不是exe啊,是不是执行对吧,那执行一个Java run,这个是,呃,就是Java命令啊Java命令。那么后面。一些JVM参数对吧,反正前面这一坨是什么一些参数吧。那这一坨呢?是不是类路径啊杠class pass对吧,这不是咱们关心的重点,咱们关心的是他执行的是哪个类,哪个类啊能看到吧。是不是这个东西。对吧,就是那个客户端的那个对吧。这是咱们的入口。
06:02
其他的参数大家现在也不用去看了,好吧,就他做的一些封装,那么至于大家可能会有疑惑,我怎么知道雅安的地址是什么呀?他肯定前面的逻辑有去加载,呃,这中间可以,呃,我们了解一个就可以了,它核心呢。是在一个文件去读取环境信息的,哪一个呢,这个。环境信息都在这里面。我把一些重点呢拿出来啊。com.SH大家知道在哪就行了,不用去具体的看,我们就瞅一眼,你看它里面是不是各种变量explore对吧,还有什么配置的并目录啊,还有依赖的啊,咱们了解这些就够了啊,那里面同样的有一些Java后对吧。还有呃,雅安的哈豆的。对这些你看雅安的对吧,关于雅安关于哈杜的,它是有一个脚本去获取的,那咱们啊也不用看那个。
07:07
所以到这为止呢,咱们现在核心刚才讲那么多,要知道什么是不是程序的入口啊,是不是这个东西啊,OK,然后这个是什么,是不是一些环境获取,对吧,环境信息的获取好。那咱们了解到这个就OK了。
我来说两句