您好,登錄后才能下訂單哦!
這篇文章主要介紹Linux系統如何安裝Flink,文中介紹的非常詳細,具有一定的參考價值,感興趣的小伙伴們一定要看完!
Flink是用Java和Scala編寫一個開源流處理框架,Flink以數據并行和流水線方式執行任意流數據程序,Flink的流水線運行時系統可以執行批處理和流處理程序。
1、下載
flink有兩個版本,一個版本是和hadoop捆綁的,另一個是單獨的,我們以單獨的為例:
flink-1.9.3-bin-scala_2.11.tgz
2、解壓
tar -zxvf flink-1.9.3-bin-scala_2.11.tgz -C /opt/
解壓到/opt/目錄下
3、配置環境變量
打開配置文件:
vi /etc/profile
配置內容如下:
# Flink
export FLINK_HOME=/opt/flink-1.9.3
export PATH=$FLINK_HOME/bin:$PATH
保存配置:
source /etc/profile
4、啟動Flink
執行
start-cluster.sh
jps查看是否啟動成功:
5、查看管理頁面
http://ip地址:8081
6、運行一個example
(1)打開第一個窗口:
監聽8888端口:
nc -lk 8888
如果沒有安裝nc,執行如下命令安裝:
yum install -y nc
(2)打開第二個窗口
進入flink安裝目錄,啟動單詞統計的java程序 SocketWindowWordCount,并監聽8888端口
flink run examples/streaming/SocketWindowWordCount.jar –port 8888
(3)打開第三個窗口
進入flink安裝目錄下的log目錄,查看統計結果:
tail -f flink-root-taskexecutor-0-bigdata111.out
以上是“Linux系統如何安裝Flink”這篇文章的所有內容,感謝各位的閱讀!希望分享的內容對大家有幫助,更多相關知識,歡迎關注億速云行業資訊頻道!
免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。