使用standalone模式，需要启动flink的主节点JobManager以及从节点taskManager
|
服务以及ip
|
192.168.52.100
|
192.168.52.110
|
192.168.52.120
|
|
JobManager
|
是
|
否
|
否
|
|
TaskManager
|
是
|
是
|
是
|
第一步：更改配置文件
停止node01服务器上面local模式下的两个进程，然后修改node01服务器配置文件
node01服务器更改flink-conf.yaml配置文件文件
node01服务器执行以下命令更改flink配置文件
cd /kkb/install/flink-1.8.1/conf/
vim flink-conf.yaml
更改这个配置，指定jobmanager所在的服务器为node01
jobmanager.rpc.address: node01
node01服务器更改slaves配置文件
node01执行以下命令更改从节点slaves配置文件
cd /kkb/install/flink-1.8.1/conf
vim slaves
node01
node02
node03
第二步：安装包分发
将node01服务器的flink安装包分发到其他机器上面去
node01服务器执行以下命令分发安装包
cd /kkb/install
scp -r flink-1.8.1/ node02:$PWD
scp -r flink-1.8.1/ node03:$PWD
第三步：启动flink集群
node01执行以下命令启动flink集群
cd /kkb/install/flink-1.8.1
bin/start-cluster.sh
第四步：页面访问
第五步：运行flink自带的测试用例
node01执行以下命令启动socket服务，输入单词
nc -lk 9000
node01启动flink的自带的单词统计程序，接受输入的socket数据并进行统计
cd /kkb/install/flink-1.8.1
bin/flink run examples/streaming/SocketWindowWordCount.jar --hostname node01 --port 9000
node01服务器执行以下命令查看统计结果
cd /kkb/install/flink-1.8.1/log
tail -200f flink-hadoop-taskexecutor-0-node01.kaikeba.com.out
