一.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/ flink2.配置环境变量
#回到家目录下
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
