温馨提示:文本由机器自动转译,部分词句存在误差,以视频为准
00:00
接下来我们就来讨论一下,在不同的资源管理平台的作用下,我们的部署模式又应该分别怎么样去应用啊,那最简单的场景其实就是没有任何的外部资源管理平台。那这种情况是什么呢?那就是刚才我们启动的啊,只有flink flink自己,它其实就可以起一个集群出来,这种方式呢,叫做stand alone stand alone大家知道它是就是所谓的单独独立的意思,所以这种模式叫做独立模式。独立模式下,就相当于是flink不借助任何的外部资源,管理平台跟别人一点关系都没有,我就是独立的一个集群。那么这个时候我们所创建的link集群里边的组件啊,都是操作系统上运行的一个JVM进程。啊,在这种情况下,就是说他的问题呢,就是资源是必须要去做手动管理的啊,所以他其实在实际项目当中使用会比较少,那前面我们启动的这个模式其实就是一个独立模式,那是独立模式的具体的哪种,前面我们提到的这个三种抽象模式里边的哪种模式呢?啊是stand alone里边的绘画模式,对吧?因为是掀起集群,然后在集群里边去提交一个一个的作业嘛。
01:20
集群的生命周期跟作业没关系。然后这个单作业部署模式呢,啊,大家注意link没有办法直接以单作业方式去启动集群啊,所以说就是说stand德洛这种集群里边没有单作业模式的这种部署方式。那最后还有就是应用模式,应用模式是存在的,为什么呢?因为flink里边它提供了单独提交一个作业的这样的一个命令。它会单独的启动一个job manager啊,所以这里可以给大家简单的看一看,我们这里就不再给大家去测了啊,因为这个使用的很少很少,一般不会这么去用,大家可以大概的看一看,这里就用到了其他的一些脚本,我们还记得那个并幕下面有很多SH文件脚本吧,那这里用到了什么呢?啊,首先我们把这一个jar包放到那个安装目录下啊,然后这里边就没有这个U外部UI了,我们就只能是执行这个命令了,怎么提交stand drop。
02:20
用这个脚本,然后start,用它的start命令,后边呢给一个杠杠job class name,把我们当前的入口类添加进来。啊,它会直接大家注意啊,前面这个jar包是要放到这个library library啊这个目录下边去。因为我们后面提交的时候,它会自动扫描这个目录,所以你看后面提交的时候根本没有指定抓包。而是直接指定入口类就可以了。啊,这是这个单独提交一个应用比较特殊的做法,这样提交了之后呢,当前扫描到lab目录下边所有的抓包。就会直接为他启动一个单独的job manager,当然也就是启动了一个集群了,大家知道一个集群里边应该不考虑这个ha啊,不考虑高可用的时候就应该只有一个manager。
03:12
然后接下来呢啊,那你还得有task manager呀,Task manager的话也是用脚本单独启动,那就是task manager sh start单独的起起来。好,然后接下来就可以执行对应的这个任务了啊,那如果要希望停掉当前这个集群呢,也不能直接去用一个命令去停,而是要分别去停job stop和task manager stop。这就是在stand模式下的不同的部署模式。
我来说两句