版本選擇:1.7.2,不整合其它元件。
格式:flink-1.7.2-bin-scala_2.11.tgz
解壓縮:tar -zxvf flink-1.7.2-bin-scala_2.11.tgz
配置環境變數:cd ~
vim .bash_profile
export flink_home=/home/alex/soft/flink
export path=$flink_home/bin:$path
export path
source .bash_profile
二:提交任務
啟動flink:./bin/start-cluster.sh
檢視webui:ip:8081,埠預設為8081
提交任務(socketwordcount)簡單測試:
說明:基於流式的單詞統計
1.啟動9999埠
nc -l 9999
2.提交任務
flink run examples/streaming/socketwindowwordcount.jar --port 9999
flink的簡單安裝
flink的優點確實是挺強的,不過公司業務用不到,都是離線的,所以說拿出來研究研究,希望以後有機會能夠用到 上傳然後解壓 解壓到自己的軟體目錄下 tar zxvf flink 1.7.1 bin hadoop27 scala 2.11.tgz cd flink 1.7.1 啟動yarn 前提裝好ya...
Flink超簡單安裝
解壓 usr local目錄下的 flink 1.10.1 bin scala 2.12.tgz 目錄 usr local sudo tar zxf flink 1.10.1 bin scala 2.12.tgz解壓完成之後得到資料夾flink 1.10.1 在 etc profile配置檔案中新增...
Flink學習(二) Flink安裝與簡單使用
最近在學習flink流處理框架,自己試著在機子上部署了個flink,這裡以簡單的local模式為例,安裝方式較為簡單,僅供學習之用,正式生產上使用的話主要有standalone集群模式,yarn模式以及k8s部署這幾種模式 這裡以最新的flink 1.11.2版本為例 官網 wgettar zxf ...