Linux系統(tǒng)中如何安裝Flink

這篇文章主要為大家展示了“Linux系統(tǒng)中如何安裝Flink”，內(nèi)容簡而易懂，條理清晰，希望能夠幫助大家解決疑惑，下面讓小編帶領(lǐng)大家一起研究并學(xué)習(xí)一下“Linux系統(tǒng)中如何安裝Flink”這篇文章吧。

Flink簡介：

在當(dāng)前的互聯(lián)網(wǎng)用戶，設(shè)備，服務(wù)等激增的時代下，其產(chǎn)生的數(shù)據(jù)量已不可同日而語了。各種業(yè)務(wù)場景都會有著大量的數(shù)據(jù)產(chǎn)生，如何對這些數(shù)據(jù)進(jìn)行有效地處理是很多企業(yè)需要考慮的問題。以往我們所熟知的Map Reduce，Storm，Spark等框架可能在某些場景下已經(jīng)沒法完全地滿足用戶的需求，或者是實現(xiàn)需求所付出的代價，無論是代碼量或者架構(gòu)的復(fù)雜程度可能都沒法滿足預(yù)期的需求。新場景的出現(xiàn)催產(chǎn)出新的技術(shù)，F(xiàn)link即為實時流的處理提供了新的選擇。Apache Flink就是近些年來在社區(qū)中比較活躍的分布式處理框架，加上阿里在中國的推廣，相信它在未來的競爭中會更具優(yōu)勢。 Flink的產(chǎn)生背景不過多介紹，感興趣的可以Google一下。Flink相對簡單的編程模型加上其高吞吐、低延遲、高性能以及支持exactly-once語義的特性，讓它在工業(yè)生產(chǎn)中較為出眾。相信正如很多博客資料等寫的那樣”Flink將會成為企業(yè)內(nèi)部主流的數(shù)據(jù)處理框架，最終成為下一代大數(shù)據(jù)處理標(biāo)準(zhǔn)?！?/p>

Linux系統(tǒng)安裝Flink具體步驟：

一、下載Flink（2種方式為了簡單我用第二種。）

1、手動下載Flink

1.1、官網(wǎng)下載:https://flink.apache.org/downloads.html#apache-flink-172

1.2、下載壓縮包 上傳服務(wù)器自己創(chuàng)建的目錄（略）。

2、自動下載Flink

 創(chuàng)建目錄： mkdir /root/kingyifan/flink
 
 下載Flink: wget mirrors.hust.edu.cn/apache/flink/flink-1.7.2/flink-1.7.2-bin-hadoop24-scala_2.11.tgz（版本號請訪問網(wǎng)站自行查詢）

具體版本號請查閱：http://mirrors.hust.edu.cn/apache/flink/

二、解壓壓縮包

 命令：tar -zxvf flink-1.7.2-bin-hadoop24-scala_2.11.tgz

解壓成功：

三、啟動Flink

 進(jìn)入bin目錄：cd /root/kingyifan/flink/flink-1.7.2/bin/
 
 啟動flink：./start-cluster.sh

查看是否啟動成功：

  命令：jps

三、centos6開放flink默認(rèn)端口（8081） 修改iptables

 進(jìn)入配置iptables：vi /etc/sysconfig/iptables
 
 增加：-A INPUT -m state --state NEW -m tcp -p tcp --dport 8081 -j ACCEPT

重啟防火墻：service iptables restart

四、訪問ui界面：192.168.241.134:8081

五、測試 5.1 先xsheel復(fù)制三個會話：

打開第一個會話：

 啟動一個終端（端口隨意）：nc -lk 8888

打開第二個會話：

 進(jìn)入bin目錄：cd /root/kingyifan/flink/flink-1.7.2/
 
 命令：bin/flink run examples/streaming/SocketWindowWordCount.jar --port 8888

打開第三個會話：

 進(jìn)入log目錄：cd /root/kingyifan/flink/flink-1.7.2/log
 
 命令：tail -f flink-root-taskexecutor-5-localhost.localdomain.out（不一定是這個日志文件）

日志目錄：

在第一個會話隨便輸入內(nèi)容

看第三個內(nèi)容：

有沒有一個疑惑 后面的1是個什么？

他在幾算多少秒內(nèi)出現(xiàn)了多少次 我們隨便輸幾個1測試一下

發(fā)現(xiàn)他已經(jīng)幾算出來了。

我們也可以看一下Running Jobs

以上是“Linux系統(tǒng)中如何安裝Flink”這篇文章的所有內(nèi)容，感謝各位的閱讀！相信大家都有了一定的了解，希望分享的內(nèi)容對大家有所幫助，如果還想學(xué)習(xí)更多知識，歡迎關(guān)注億速云行業(yè)資訊頻道！