本次主要介紹flink1.5.1版本的本地環境安裝部署,該版本要求jdk版本1.8以上。 ...
本次主要介紹flink1.5.1版本的本地環境安裝部署,該版本要求jdk版本1.8以上。
- 下載flink安裝包:http://archive.apache.org/dist/flink/flink-1.5.1/
- 解壓flink安裝包
tar -zxvf flink-1.5.1-bin-hadoop27-scala_2.11.tgz -C /opt/software/
- 修改配置文件slaves和masters,將主機名修改為對應本地主機名
- 啟動flink
bin/start-cluster.sh
- 通過jps檢查進程是否存在:StandaloneSessionClusterEntrypoint、TaskManagerRunner
- 查看flink的WEBUI界面:http://bigdata01:8081