Flink SQL 知其所以然:Flink SQL 開發利器之 Zeppelin
本文轉載自微信公眾號「大數據羊說」,作者antigeneral了呀 。轉載本文請聯系大數據羊說公眾號。
1.序篇
上節介紹了 flink sql 的企業級開發利器 Dlink。本節就來介紹下 Apache Zeppelin。
本節主要介紹一下博主在本地部署 Apache Zeppelin 的過程以及感受。
先說下安裝感受,Apache Zeppelin 安裝起來真的是非常的方便!!!
幾步就完成了。
2.Apache Zeppelin 平臺效果
具體功能如下圖所示:
sql 開發
sql 開發
3.安裝部署篇
安裝真的很簡單。
可以參考 jeff 大佬的安裝教程,也可以參考博主本文的安裝教程。
jeff 大佬安裝教程:https://www.yuque.com/jeffzhangjianfeng/gldg8w/bam5y1
3.1.安裝 flink
這一步是為了配置 flink 的環境。
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 復制到 opt 目錄下
lib
然后就完成了本地 flink 環境的配置。
3.2.下載 zeppelin 的 tar 包
這一步是為了配置 zeppelin 的環境。
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 環境信息
按照下面的步驟配置環境信息。
環境
然后我們就可以直接在 Zeppelin 中編輯 sql 了。
sql 腳本
預制案例
可以看到上述流程是非常簡單的。
幾乎沒有什么學習和復雜配置的成本。
推薦大家可以嘗試安裝。
真的是肥腸的方便。