赞
踩
#解压重命名
cd /opt/download/
tar -zxvf flink-1.12.7-bin-scala_2.12.tgz -C /opt/software/
cd /opt/software/flink-1.12.7
#配置环境变量
vim /etc/profile.d/my.sh
---------------------------------------------------------
flink-1.12.7
export FLINK_HOME=/opt/software/flink-1.12.7
export PATH=$PATH:$FLINK_HOME/bin
---------------------------------------------------------
#激活环境变量
source /etc/profile
#启动与关闭
(base) [root@single01 bin]# pwd
/opt/software/flink-1.12.7/bin
(base) [root@single01 bin]# ./start-cluster.sh
(base) [root@single01 bin]# jps
1429 Jps
1079 StandaloneSessionClusterEntrypoint
1354 TaskManagerRunner
1079
(base) [root@single01 ~]# jps
4097 Jps
1079 StandaloneSessionClusterEntrypoint
1354 TaskManagerRunner
(base) [root@single01 ~]# kill -9 1079
(base) [root@single01 ~]# kill -9 1354
#Flink可视化工具
http://single01:8081/
#Flink配置信息
(base) [root@single01 conf]# pwd
/opt/software/flink-1.12.7/conf
(base) [root@single01 conf]# vim flink-conf.yaml
60 taskmanager.numberOfTaskSlots: 1 #每个task上的slot数目
64 parallelism.default: 1
#Flink设置并行度优先级
代码程序:env.setParallelism(1)
Flink Client (页面): ./bin/flink -p 2
flink-conf.yaml配置:parallelism.default: 1
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。