一、环境配置
需要安装JDK
参考步骤:https://blog.csdn.net/wd520521/article/details/109769429
二、安装
1、下载
flink-1.10.1-bin-scala_2.12.tgz
2、解压
#解压到/opt/目录下
tar -zxvf flink-1.10.1-bin-scala_2.12.tgz -C /opt/
3、配置环境
(1)打开配置文件:
vim /etc/profile
(2)配置内容如下:
# Flink
export FLINK_HOME=/opt/flink-1.10.1
export PATH=$FLINK_HOME/bin:$PATH
(3)保存配置:
source /etc/profile
4、启动Flink
(1)启动命令
start-cluster.sh
(2)jps查看是否启动成功:
5、查看管理页面
6、运行一个example
(1)打开第一个窗口:
监听8888端口:
nc -lk 8888
如果没有安装nc,执行如下命令安装:
yum install -y nc
(2)打开第二个窗口
进入flink安装目录,启动单词统计的java程序 SocketWindowWordCount,并监听8888端口
flink run examples/streaming/SocketWindowWordCount.jar --port 8888
(3)打开第三个窗口
进入flink安装目录下的log目录,查看统计结果:
#不同服务器日志文件不一样
tail -f flink-root-taskexecutor-0-bigdata111.out
7、停止运行
stop-cluster.sh
集群分配:
192.168.124.101,bigdata111(master)
192.168.124.102,bigdata112(worker)
192.168.124.103,bigdata113(worker)
在安装前,每台机器需要安装JDK(https://blog.csdn.net/wd520521/article/details/109769429)
1、master安装
配置Flink安装目录下的conf/flink-conf.yaml
默认如下:
jobmanager.rpc.address: localhost
jobmanager.heap.size: 1024m
taskmanager.heap.size: 1024m
修改为:
jobmanager.rpc.address: bigdata111
conf/slaves
默认如下:
localhost
修改为:
bigdata112
bigdata113
2、worker安装
将配置好的master复制到worker中,保存目录相同。
scp -r flink-1.10.3 root@bigdata112:/opt/
scp -r flink-1.10.3 root@bigdata113:/opt/
3、启动集群
在master节点上执行start-cluster.sh命令启动集群。然后jps查看各节点启动情况,如图:
4、停止集群
执行stop-cluster.sh命令即可,如图: