```shell tar -zxvf flink-1.6.4-bin-hadoop27-scala_2.11.tgz -C /opt/ ``` ```shell mv /opt/flink-1.6.4/ /opt/flink ``` ```shell vi /opt/flink/conf/flink-conf.yaml # 1 ``` ```yaml jobmanager.rpc.address: flink01 ``` ```shell vi /opt/flink/conf/masters # 2 || echo "flink01:8081" >/opt/flink/conf/masters ``` ``` flink01:8081 ``` ```shell vi /opt/flink/conf/slaves # 3 ``` ``` flink02 flink03 ``` --- 分發文件 切記：不同服務器之間的flink文件夾位置保持一致！ ```shell scp -r /opt/flink/ root@flink02:/opt/ ``` ```shell scp -r /opt/flink/ root@flink03:/opt/ ``` --- 以下步驟在集群節點均需配置 ```shell echo "export FLINK_BIN_DIR=/opt/flink/bin" >>/etc/profile \ && echo "export PATH=\$PATH:\$FLINK_BIN_DIR" >>/etc/profile \ && source /etc/profile ``` --- 啟動集群 ```shell /opt/flink/bin/start-cluster.sh ``` 關閉集群 ```shell /opt/flink/bin/stop-cluster.sh ``` 訪問：[http://flink01:8081/](http://flink01:8081/) > 單節點啟動與停止 ```shell /opt/flink/bin/jobmanager.sh ((start|start-foreground) cluster)|stop|stop-all /opt/flink/bin/taskmanager.sh start|start-foreground|stop|stop-all ``` 運行測試任務（啟動Hadoop） ```shell /opt/flink/bin/flink run /opt/flink/examples/batch/WordCount.jar --input hdfs://flink01:9000/input/part1rfid0901.txt --output hdfs://flink01:9000/output/part1rfid0901.output.txt ``` Hadoop：[http://flink01:50070/](http://flink01:50070/)