前期軟件下載略過喝滞,直接進入部署
解壓及配置
tar -xzvf xxxxxx.gz
需要配置文件有conf/flink-conf.yaml艰赞、worker 莱褒、master
配置完之后進入bin目錄浴栽,啟動cluster
啟動
./start-cluster
ip:8081訪問頁面
https://nmap.org/dist/ncat-7.95-2.x86_64.rpm
測試
安裝ncat
rpm -ivh ncat-7.91-1.x86_64.rpm
啟動ncat服務
<1>ncat -lk 9999
另外一個Session監(jiān)聽ncat
<2>ncat localhost 9999
新開個Session啟動word count程序
<3>bin/flink run examples/streaming/SocketWindowWordCount.jar --hostname 實際IP地址 --port 9999
在<1>里輸入單詞回車后查看flink ui界面中的taksmanager荒叼,顯示出了輸入的單詞