使用standalone模式货岭，需要啟動flink的主節(jié)點JobManager以及從節(jié)點taskManager
|
服務以及ip
|
192.168.52.100
|
192.168.52.110
|
192.168.52.120
|
|
JobManager
|
是
|
否
|
否
|
|
TaskManager
|
是
|
是
|
是
|
第一步：更改配置文件
停止node01服務器上面local模式下的兩個進程，然后修改node01服務器配置文件
node01服務器更改flink-conf.yaml配置文件文件
node01服務器執(zhí)行以下命令更改flink配置文件
cd /kkb/install/flink-1.8.1/conf/
vim flink-conf.yaml
更改這個配置冰肴，指定jobmanager所在的服務器為node01
jobmanager.rpc.address: node01
node01服務器更改slaves配置文件
node01執(zhí)行以下命令更改從節(jié)點slaves配置文件
cd /kkb/install/flink-1.8.1/conf
vim slaves
node01
node02
node03
第二步：安裝包分發(fā)
將node01服務器的flink安裝包分發(fā)到其他機器上面去
node01服務器執(zhí)行以下命令分發(fā)安裝包
cd /kkb/install
scp -r flink-1.8.1/ node02:$PWD
scp -r flink-1.8.1/ node03:$PWD
第三步：啟動flink集群
node01執(zhí)行以下命令啟動flink集群
cd /kkb/install/flink-1.8.1
bin/start-cluster.sh
第四步：頁面訪問
第五步：運行flink自帶的測試用例
node01執(zhí)行以下命令啟動socket服務勺拣，輸入單詞
nc -lk 9000
node01啟動flink的自帶的單詞統(tǒng)計程序奶赠，接受輸入的socket數(shù)據(jù)并進行統(tǒng)計
cd /kkb/install/flink-1.8.1
bin/flink run examples/streaming/SocketWindowWordCount.jar --hostname node01 --port 9000
node01服務器執(zhí)行以下命令查看統(tǒng)計結(jié)果
cd /kkb/install/flink-1.8.1/log
tail -200f flink-hadoop-taskexecutor-0-node01.kaikeba.com.out
