flink的standalone模式环境搭建

一.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包

      ![](https://img-blog.csdnimg.cn/e44b3ced1d424896beb8e861cbfe5e33.png)

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

       ![](https://img-blog.csdnimg.cn/c998f82195ce418f9800f05f1b5d5e8b.png)

       ![](https://img-blog.csdnimg.cn/4d7a936c3d4c4566babbcecf152492fd.png) 

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

      ![](https://img-blog.csdnimg.cn/fc8c3280bee34a2c937a72ca9c9fae3a.png)

     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