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