一、下載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。有什么問題可以聯系我哈。
鼓勵作者寫出更好的技術文檔,就請我喝一瓶哇哈哈哈哈哈哈哈。。你們的贊助決定我更新的速度哦!
微信:
支付寶:
感謝一路支持我的人。。。。。
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)