00:00
那么接下来我们来试一试雅安session的模式,那后面演示呢,我就都用雅安session啊,这样更灵活一点啊啊就不会固定启动三个TM占用资源都可以啊,都无所谓啊呃,那雅安session来我们呃,首先第。就是咱们启动的时候啊,第一个先不用看啊,先看后面这个啊也是一样的,你要用circle client,你必须事先启动一个flink集群,那雅安的话,事先启动的集群就是雅安session啊,Job那些是现提交作业,现启动独立集群啊,不一样,这种不适合于s circle client啊,啊也可以,但不适合啊,一般我们还是用雅session。共享集群就是多个作业都可以什么提交到这个雅安集群session集群,好,那就是先正常的启动一个雅安模式的flink集群,启动完之后咱们就可以用circle client去。连接这个session集群,那这个时候我们要加一个杠S。
01:03
杠S,然后呢,写上一个固定的雅安session,这样的话它就会去往雅安连接的,大家仔细看那个日志就可以了。好,那大家注意看上面这里并没有说它是雅安筛选对吧,这里没有出现雅安相关的字眼啊,没有行,我先把之前这个logo集群退出啊,我先把老集群停掉啊。这个是logo集群,先停掉啊。好,现在停完了对吧,那还是一样的,咱们是什么呢?呃,这些flink配置还是保持这个啊这个一样啊这个一样,那做过了就不再做了,接下来我们去启动一个什么雅安session-D啊后台执行。等一会儿让他启动啊。你看现在正在什么,正在部署集群对吧?啊。
02:04
当前是接收中来,我们直接看一下吧,8088,你看现在是running对吧。这是一个session cluster。而且现在启动了什么,只有一个容器对不对?来我们点开这个we UI过UI通过这里点啊啊,点开之后大家可以看到现在TM的数量是什么零,这个我说过了,它是动态申请的,你有作业提交,有需求了我再帮你申请啊,那有剩余的它就注销掉啊,释放掉啊,这也是雅安session自动管理TM数量啊,非常舒服啊。可以叫弹性伸缩嘛,对吧,啊不浪费资源好。这就正常启动了,对吧,那么接下来咱们就是什么呢?B circle client,然后呢,还是embedded-S雅安杠session。
03:03
好回车。那我们看看这里这里的日志啊,这一次的日志还不太一样的,看我命令是从这边开始敲的,那这边大家可以看到in four里面它是什么。雅安session tonight。对吧,他找到什么,雅安的配置文件在哪里呢?在TP点雅安properties at硅谷。它其实就是就是咱们circle client连接什么样的集群,其实有一个判断条件,就是我在tmp这个路径能找到这个配置文件,它就会去连session集群啊,如果找不到他就去连啊,尝试着去连我们那种正常的stand alone集群啊。好,那接下来你可以受贝塔basis对吧?So tables。
04:03
那么有细心的同学应该发现了,诶,我这一步好像没做,就是拷贝一个哈杜尔的价包,说是要解决依赖问题是吧?诶,我不是配置了class pass吗?他怎么还要解决这个依赖问题啊,有时候就是会这样啊,比如说你在flink Li下面引入了,我举个例子啊,引入了have connect。就是你加了一些其他依赖,那这些依赖里面可能内部啊,跟你的哈杜克环境就会有一个冲突的问题,也就是说很多时候大家在用的时候,就只要你放的have,尤其是have have相关的依赖,什么have eec啊,Have connect这些东西一放到live里边就开始执行的时候各种报错,什么找不到类啊,找不到方法,其实就是什么依赖冲突,那最简单的解决方案呢,就是你拷贝一个哈杜的包过来就可以了啊,这个这个Mr client core这个包过来就行,行,那我现在不做呢,就是为了让大家产生印象,那后面我执行的时候,如果遇到这个问题,我再反过来,诶,我们再来看这里。
05:11
好了,那现在就是两种方式,那后续的演示我都会基于什么呢?雅安session的方式啊啊来演示。
我来说两句