flink的安裝和簡單測試

2022-05-09 03:33:09 字數 562 閱讀 6011

版本選擇: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 ...