前期軟件下載略過(guò)，直接進(jìn)入部署

解壓及配置

tar -xzvf xxxxxx.gz
需要配置文件有conf/flink-conf.yaml、worker 、master

配置完之后進(jìn)入bin目錄，啟動(dòng)cluster

啟動(dòng)

./start-cluster
ip:8081訪問(wèn)頁(yè)面

https://nmap.org/dist/ncat-7.95-2.x86_64.rpm

測(cè)試

安裝ncat
rpm -ivh ncat-7.91-1.x86_64.rpm

啟動(dòng)ncat服務(wù)
<1>ncat -lk 9999

另外一個(gè)Session監(jiān)聽(tīng)ncat
<2>ncat localhost 9999

新開(kāi)個(gè)Session啟動(dòng)word count程序
<3>bin/flink run examples/streaming/SocketWindowWordCount.jar --hostname 實(shí)際IP地址 --port 9999

在<1>里輸入單詞回車(chē)后查看flink ui界面中的taksmanager，顯示出了輸入的單詞

image.png