Flink安裝極簡教程-單機版


一:安裝

Flink官網下載地址:https://flink.apache.org/downloads.html

選擇1.6.3版本

 下載:

wget http://mirrors.hust.edu.cn/apache/flink/flink-1.7.1/flink-1.7.1-bin-hadoop26-scala_2.11.tgz

解壓:

tar -zxvf flink-1.6.3-bin-hadoop26-scala_2.11.tgz
mv  flink-1.6.3 flink

查看本機host

進入flink目錄,修改conf/flink-conf.yaml文件

vim  conf/flink-conf.yaml

修改conf/masters文件,修改后內容如下:

啟動單機版flink:

bin/start-cluster.sh

啟動界面如下:

查看啟動是否成功:

 查看dashboard界面:http://192.168.186.129:808

 

二:官方案例演示

1.啟動一個終端輸入如下指令:

nc -lk 8000

2.啟動第二個終端,執行flink自帶的wordcount案例

bin/flink run examples/streaming/SocketWindowWordCount.jar --port 8000

3.在第一個終端發送數據:

4.測試結果保存在log/flink-root-taskexecutor-0-woniu.out文件中

5. Dashboard也可以看到任務信息

 

 

 


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM