1.安裝flink
下載壓縮包wget https://archive.apache.org/dist/flink/flink-1.11.0/flink-1.11.0-bin-scala_2.11.tgz
等待下載报慕。
下載完成后需了，解壓縮：tar -xzf flink-1.11.0-bin-scala_2.11.tgz
2.配置環(huán)境變量
輸入export FLINK_HOME=/usr/local/flink-1.11.0和export PATH=$PATH:$FLINK_HOME/bin
3.根據(jù)本機(jī)的資源（CPU枕赵、內(nèi)存大小）修改flink-1.11.0/conf/flink-conf.yaml
image.png
image.png
taskmanager.numberOfTaskSlots: 120
jobmanager.memory.process.size: 4096m
taskmanager.memory.process.size: 4096m
4.測(cè)試start
image.png
如上圖所示，共使用4種方式進(jìn)行start測(cè)試魄鸦，只有第四種方式啟動(dòng)成功壁畸，前三種flink啟動(dòng)異常。
- 第一種患雏，輸入
start-cluster.sh鹏溯，失敗 - 第二種，進(jìn)入start-cluster.sh文件所在路徑后輸入
start-cluster.sh淹仑，失敗 - 第三種丙挽，在start-cluster.sh文件所在路徑輸入
sh start-cluster.sh，失敗 - 第四種匀借，輸入
./start-cluster.sh颜阐，啟動(dòng)flink集群成功
5.測(cè)試stop
image.png
如上圖所示，輸入
./stop-cluster.sh吓肋，成功
