一 建立flink包
下載下傳flink parcel
# git clone https://github.com/pkeropen/flink-parcel.git
1.需要提前安裝maven,執行編譯腳本的需要用
# yum -y install maven
# chmod 744 build.sh
2. 配置flink-parcel.properties
#FLINK 下載下傳位址
FLINK_URL=https://archive.apache.org/dist/flink/flink-1.9.1/flink-1.9.1-bin-scala_2.12.tgz
#flink版本号
FLINK_VERSION=1.9.1
#擴充版本号
EXTENS_VERSION=BIN-SCALA_2.12
#作業系統版本,以centos為例
OS_VERSION=7
#CDH 小版本
CDH_MIN_FULL=5.2
CDH_MAX_FULL=6.3.2
#CDH大版本
CDH_MIN=5
CDH_MAX=6
3.執行腳本,生成parcel和csd檔案
# ./build.sh parcel #生成parcel檔案
# ./build.sh csd_on_yarn #生成csd檔案, 會生産一個jar包,FLINK_ON_YARN-1.10.0.jar
- 把FLINK_ON_YARN-1.9.1.jar 檔案放在本地的/opt/cloudera/csd/,CDH服務識别flink的時候需要用
# cp FLINK_ON_YARN-1.9.1.jar /opt/cloudera/csd/ #本地cdh能識别這個軟體的目錄下
二 CM內建安裝flink
1.cm配置flink parcel。如果是直接拷貝到本地的,可以不配置。
2.需要激活flink,要不然無法完成安裝 下載下傳—>>配置設定—>>激活
3.添加flink服務
4.完成配置