title: Flink系列
二、Flink集群搭建
2.1 Flink的Standalone模式集群安装
1、上传解压重命名
[root@hadoop10 software]# tar -zxvf flink-1.14.3-bin-scala_2.12.tgz
[root@hadoop10 software]# mv flink-1.14.3 flink
2、进入到解压之后的目录里面修改配置文件flink-conf.yaml
[root@hadoop10 conf]# cd /software/flink/conf/
[root@hadoop10 conf]# vim flink-conf.yaml
修改jobmanager.rpc.address 如下:
jobmanager.rpc.address: hadoop10
截图如下:
3、修改masters为如下
[root@hadoop10 conf]# vim masters
[root@hadoop10 conf]# cat masters
hadoop10:8081
[root@hadoop10 conf]#
4、修改workers为如下
[root@hadoop10 conf]# vim workers
[root@hadoop10 conf]# cat workers
hadoop11
hadoop12
[root@hadoop10 conf]#
5、分发到hadoop11、hadoop12节点
scp -r /software/flink hadoop11:/software/
scp -r /software/flink hadoop12:/software/
6、启动集群
在hadoop10上面启动
[root@hadoop10 bin]# cd /software/flink/bin/
[root@hadoop10 bin]# start-cluster.sh
Starting cluster.
Starting standalonesession daemon on host hadoop10.
Starting taskexecutor daemon on host hadoop11.
Starting taskexecutor daemon on host hadoop12.
[root@hadoop10 bin]#
7、启动之后各个节点上面的进程
主节点hadoop10:
[root@hadoop10 bin]# jps
5041 StandaloneSessionClusterEntrypoint
5162 Jps
从节点hadoop11:
[root@hadoop11 software]# jps
4721 TaskManagerRunner
4822 Jps
从节点hadoop12:
[root@hadoop12 software]# jps
4678 TaskManagerRunner
4782 Jps
8、浏览器中访问页面查看
访问链接: http://hadoop10:8081
正常启动之后页面如下显示:
2.2 其他模式后面学完一些知识之后再讲解。需要更多的理论支撑。
声明:
文章中代码及相关语句为自己根据相应理解编写,文章中出现的相关图片为自己实践中的截图和相关技术对应的图片,若有相关异议,请联系删除。感谢。转载请注明出处,感谢。
By luoyepiaoxue2014
B站: https://space.bilibili.com/1523287361 点击打开链接
微博地址: http://weibo.com/luoyepiaoxue2014 点击打开链接