Zepplin 從0.9 版本（當(dāng)前該版本還未release恋追，只有預(yù)覽版）開始支持Flink最新版本1.10厘线，鑒于Flink1.10版本全面合入了Blink能力，在sql使用上展現(xiàn)出強大實力粱甫，筆者決定使用其預(yù)覽版嘗鮮搂漠。
下載安裝
在Zeppelin官網(wǎng)下載頁面可以下載到當(dāng)前zeppelin-0.9預(yù)覽版
放置在節(jié)點，并解壓后查看到目錄結(jié)構(gòu)如下：
-
進入zeppelin配置目錄亮隙，將
1. 執(zhí)行cp zeppelin-site.xml.template zeppelin-site.xml可以服務(wù)的配置ip途凫，port等 3. 執(zhí)行cp zeppelin-env.sh.template zeppelin-env.sh 可以配置相關(guān)服務(wù)的環(huán)境變量 -
啟動zeppenlin服務(wù)
${ZEEPELIN_HOME}/bin/zeppelin-daemon.sh start
Flink服務(wù)的安裝與配置
? Flink的安裝可以參考Flink on yarn setup
Zeppelin on flink 配置
使用瀏覽器登錄zeppelin頁面（默認是localhost:8080），點擊右側(cè)用戶名進入interpreter頁面溢吻，找到flink欄相關(guān)內(nèi)容维费，設(shè)置如下幾個參數(shù)：
| 配置（key） | 值(value) |
|---|---|
| FLINK_HOME | /data/cyq/flink-1.10.0 |
| HADOOP_CONF_DIR | /data/cyq/flink-1.10.0/hadoop_conf/ |
| flink.execution.mode | yarn |
| flink.yarn.appName | your app name |
| flink.yarn.queue | your yarn queue name |
Zeppelin on flink 作業(yè)提交
登錄zeppelin頁面，點擊Notebook -> Flink Tutorial -> Streaming ETL進入demo頁面（如下）促王，點擊相關(guān)啟動即可犀盟。
Zeppelin
