环境需求
- Java
- FlinK
集群规划
服务器 | 服务 |
redis01 | JobManager、TaskManager |
redis02 | TaskManager |
redis03 | TaskManager |
安装
1. 解压
root@redis01:/usr/local# tar -zxvf flink-1.14.3-bin-scala_2.12.tgz
2. 重命名
# 重命名 root@redis01:/usr/local# mv flink-1.14.3 flink-standalone
配置
root@redis01:/usr/local/flink-standalone# vim conf/flink-conf.yaml
参数设置，指定jobmanager所在的服务器为redis01
jobmanager.rpc.address: redis01
修改master文件
root@redis01:/usr/local/flink-standalone# vim conf/workers
redis01:8081
修改workers文件
root@redis01:/usr/local/flink-standalone# vim conf/workers
redis01 redis02 redis03
安装分发
分发到集群其他机器redis02、redis03。
root@redis01:/usr/local# xsync flink-standalone/
启动Flink集群
root@redis01:/usr/local/flink-standalone# ./bin/start-cluster.sh
- xcall是我写的jps脚本，查看jps，集群启动成功。
访问WebUI
测试
- redis01执行命令启动socket服务，输入单词
root@redis01:~# nc -lk 9000
- redis01启动flink的自带的单词统计程序，接受输入的socket数据并进行统计
root@redis01:/usr/local/flink-standalone# ./bin/flink run examples/streaming/SocketWindowWordCount.jar --hostname redis01 --port 9000
- redis01服务器执行以下命令查看统计结果
root@redis01:/usr/local/flink-standalone/log# tail -200f flink-root-taskexecutor-1-redis01.out
关闭Flink集群
root@redis01:/usr/local/flink-standalone# ./bin/stop-cluster.sh
