Linux安裝flink


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

1、手動下載Flink

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

file

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

2、自動下載Flink

file

創建目錄: 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/

file

二、解壓壓縮包

file

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

解壓成功:

file

三、啟動Flink

file

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

查看是否啟動成功:

file

 命令:jps

三、centos6開放flink默認端口(8081) 修改iptables

file

進入配置iptables:vi /etc/sysconfig/iptables
增加:-A INPUT -m state --state NEW -m tcp -p tcp --dport 8081 -j ACCEPT

重啟防火牆:service iptables restart

file

四、訪問ui界面:192.168.241.134:8081

file

五、測試 5.1 先xsheel復制三個會話:

file

打開第一個會話:

file

啟動一個終端(端口隨意):nc -lk 8888 

打開第二個會話:

file

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

打開第三個會話:

file

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

日志目錄:

file

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

file

看第三個內容:

file

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

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

file

發現他已經幾算出來了。

file

我們也可以看一下Running Jobs

file

終、、


以上linux安裝以及部署flink。有什么問題可以聯系我哈。

鼓勵作者寫出更好的技術文檔,就請我喝一瓶哇哈哈哈哈哈哈哈。。你們的贊助決定我更新的速度哦!

微信:

支付寶:


感謝一路支持我的人。。。。。

Love me and hold me
QQ:69673804(16年老號)
EMAIL:itw@tom.com
友鏈交換
如果有興趣和本博客交換友鏈的話,請按照下面的格式在評論區進行評論,我會盡快添加上你的鏈接。

網站名稱:KingYiFan’S Blog
網站地址:http://blog.cnbuilder.cn
網站描述:年少是你未醒的夢話,風華是燃燼的彼岸花。
網站Logo/頭像: [頭像地址](https://blog.cnbuilder.cn/upload/2018/7/avatar20180720144536200.jpg)

 


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM