1.安裝git
查看是否安裝了git
git --help
如果沒有git，那就安裝
yum install git
2.設定version變數
VERSION=`hdp-select status hadoop-client | sed 's/hadoop-client - \([0-9]\.[0-9]\).*/\1/'`
echo $VERSION
3.下載ambari-flink-service服務
sudo git clone https://github.com.cnpmjs.org/abajwa-hw/ambari-flink-service.git /var/lib/ambari-server/resources/stacks/HDP/$VERSION/services/FLINK
要點：直接http://github.com運行不通，需要將其替換為鏡像網站：https://github.com.cnpmjs.org
4.配置本地下載源
通過鏈接下載好檔案：
http://archive.apache.org/dist/flink/flink-1.9.1/flink-1.9.1-bin-scala_2.11.tgz
https://repo.maven.apache.org/maven2/org/apache/flink/flink-shaded-hadoop-2-uber/2.6.5-7.0/flink-shaded-hadoop-2-uber-2.6.5-7.0.jar
創建flink本地源檔案夾
cd /var/www/html/
mkdir flink
然后將檔案放到/var/www/html/flink檔案夾下
5.修改要下載的flink版本（可以直接默認則跳過本步驟，如果需要則修改）
vim /var/lib/ambari-server/resources/stacks/HDP/2.6/services/FLINK/metainfo.xml
找到版本設定，修改為你想要的版本：
<version>1.9.1</version>
6.修改下載地址(針對2.6版本)
vim /var/lib/ambari-server/resources/stacks/HDP/2.6/services/FLINK/configuration/flink-ambari-config.xml
將其中的：
<property>
<name>flink_download_url</name>
<value>http://www.us.apache.org/dist/flink/flink-1.9.1/flink-1.9.1-bin-scala_2.11.tgz</value>
<description>Snapshot download location. Downloaded when setup_prebuilt is true</description>
</property>
改為：
<property>
<name>flink_download_url</name>
<value>http://主節點ip地址/flink/flink-1.9.1-bin-scala_2.11.tgz</value>
<description>Snapshot download location. Downloaded when setup_prebuilt is true</description>
</property>
如果前面修改過版本，這里需要將鏈接里面的版本同步
7.重啟ambari服務
ambari-server restart
8.在ambari可視化界面里面安裝flink
進入控制頁面，點擊“admin”，在Stack and Versions里面找到Flink服務，點擊Add Service安裝，
一直next到Customize Services后在Advanced flink-env里面的content最底下找到
env.java.home: /usr/jdk64/jdk1.8.0_77/jre
改為
env.java.home: /usr/java/jdk1.8.0_141/ #此處為你電腦里面的Java環境目錄
然后到Custom flink-env下點擊Add Property并在視窗添加
yarn.client.failover-proxy-provider=org.apache.hadoop.yarn.client.ConfiguredRMFailoverProxyProvider
然后一直點擊下一步直到安裝完成
轉載請註明出處，本文鏈接：https://www.uj5u.com/qita/316438.html
標籤：其他
上一篇：Flume基礎