flink的standalone模式环境搭建

Posted 2022-05-27 奶糖~

一.standalone模式

所有的资源都由flink自己管理

flink的jar包：flink-1.11.2-bin-scala_2.11.tgz

把安装包放到linux中

bin  #服务或命令
conf #配置文件
examples #实例，案例
lib  #jar包
log  #日志

1.解压缩

tar -xzvf flink-1.11.2-bin-scala_2.11.tgz 

修改名字

mv flink-1.11.2/ flink

2.配置环境变量

#回到家目录下
cd 
#修改环境变量
vi .bashrc
export FLINK_HOME=/path/flink
PATH=$PATH:$FLINK_HOME/bin
source .bashrc

3.修改配置文件

standalone模式不需要修改配置文件

4.启动服务

进去到 bin/ 目录下

#开启集群
start-cluster.sh

5.验证

   1） jps验证，出现standaloneSessionClusterEntrypoint和TaskManagerRunner服务

   2）验证WebUI

         在浏览器访问  ：host：8081

 

Running Jobs:正在运行的job
completed Jobs:已经完成的job
task Managers: 从节点
Job manager: 主节点
Submit New Job : 提交新任务Job
另一种提交方式：打成jar包，放在linux里面，通过命令行的形式进行提交
task slots: 静态资源 ，默认为1

 6.两个验证都出现，则成功搭建flink

 7.提交任务

  1）WebUI直接提交job任务

并行度必须小于slots的数量，否则无法执行，报超时

       a.在ide中把代码打成jar包

          

        b. 在webUI上进入submit new job --> add new -->选择这个jar包

           

            

Entry Class:打开idea，右击添加的class类，copy reference
Program Arguments: 文件路径 --input D:/wordCount.txt
Parallelism: 并行度

          

         c. 提交

              在WebUI -->TestManager --> stdOut 查看结果(需要刷新)

               在WebUI -->Job Manager --> log 查看运行日志，也可以取消任务

  2）使用命令行直接提交

         a.在ide中把代码打成jar包

         b.把jar包拽到linux环境下

mkdir flink
#查看帮助文档 
flink
#命令行 -c 文件路径  -p 并行度 --host --port 参数
flink run -c Demo2_WordCount_DataStream -p 1 ./file/flink/myScala-1.0-SNAPSHOT.jar --host node160 --port 8888

        c.开启实时数据    

nc -lk 8888
#在窗口中输入数据 在WebUI中查看数据

         d.查看flink状态

#Running 正在运行
flink list
#查看所有job任务
flink list -a
#查看结果
webUI-> TaskMaranger -> stdout

  

  

        e.取消命令

#6e99d73175377d332dcd82252ba5dd8f id
flink cancel jobid(6e99d73175377d332dcd82252ba5dd8f )

         f.关闭集群服务

stop-cluster.sh