Linux系統中如何安裝Flink

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

Flink簡介：

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

Linux系統安裝Flink具體步驟：

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

1、手動下載Flink

1.1、官網下載:https://flink.apache.org/downloads.html#apache-flink-172

1.2、下載壓縮包 上傳服務器自己創建的目錄（略）。

2、自動下載Flink

 創建目錄： 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（版本號請訪問網站自行查詢）

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

二、解壓壓縮包

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

解壓成功：

三、啟動Flink

 進入bin目錄：cd /root/kingyifan/flink/flink-1.7.2/bin/
 
 啟動flink：./start-cluster.sh

查看是否啟動成功：

  命令：jps

三、centos6開放flink默認端口（8081） 修改iptables

 進入配置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復制三個會話：

打開第一個會話：

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

打開第二個會話：

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

打開第三個會話：

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

日志目錄：

在第一個會話隨便輸入內容

看第三個內容：

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

他在幾算多少秒內出現了多少次 我們隨便輸幾個1測試一下

發現他已經幾算出來了。

我們也可以看一下Running Jobs

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