Flink SQL 知其所以然:Flink SQL 開發(fā)利器之 Zeppelin
本文轉(zhuǎn)載自微信公眾號「大數(shù)據(jù)羊說」,作者antigeneral了呀 。轉(zhuǎn)載本文請聯(lián)系大數(shù)據(jù)羊說公眾號。
1.序篇
上節(jié)介紹了 flink sql 的企業(yè)級開發(fā)利器 Dlink。本節(jié)就來介紹下 Apache Zeppelin。
本節(jié)主要介紹一下博主在本地部署 Apache Zeppelin 的過程以及感受。
先說下安裝感受,Apache Zeppelin 安裝起來真的是非常的方便!!!
幾步就完成了。
2.Apache Zeppelin 平臺效果
具體功能如下圖所示:
sql 開發(fā)
sql 開發(fā)
3.安裝部署篇
安裝真的很簡單。
可以參考 jeff 大佬的安裝教程,也可以參考博主本文的安裝教程。
jeff 大佬安裝教程:https://www.yuque.com/jeffzhangjianfeng/gldg8w/bam5y1
3.1.安裝 flink
這一步是為了配置 flink 的環(huán)境。
https://archive.apache.org/dist/flink/flink-1.13.2/
flink 下載
點擊鏈接之后可以直接下載。
下載完成之后直接 tar -xvf jar 包解壓就行。
就得到了以下的 flink 目錄。
flink dir
我們要把 lib 目錄下的 flink-python_2.11-1.13.2.jar 復(fù)制到 opt 目錄下
lib
然后就完成了本地 flink 環(huán)境的配置。
3.2.下載 zeppelin 的 tar 包
這一步是為了配置 zeppelin 的環(huán)境。
https://zeppelin.apache.org/download.html
點擊上述鏈接直接下載:博主這里為了使用方便直接下載包含所有 interpreter 的包,下載完成之后直接 tar -xvf jar 包解壓就行。
zeppelin 下載
得到以下目錄。
zeppelin 下載
直接 bin/zeppelin-daemon.sh start 就完事了??吹较旅娴?console,就代表啟動成功了。
start
打開 localhost:8080 就可以直接看到頁面了。看到下面的頁面說明就沒啥問題了。
首頁
3.3.在 zeppelin 中配置 flink 環(huán)境信息
按照下面的步驟配置環(huán)境信息。
環(huán)境
然后我們就可以直接在 Zeppelin 中編輯 sql 了。
sql 腳本
預(yù)制案例
可以看到上述流程是非常簡單的。
幾乎沒有什么學(xué)習(xí)和復(fù)雜配置的成本。
推薦大家可以嘗試安裝。
真的是肥腸的方便。