軟體安裝版本號說明:
JDK：1.8.0_302
Flink：flink-1.14.2-bin-scala_2.11
linux：CentOS 7.0
一、安裝
1.官網下載(https://flink.apache.org/downloads.html) Apache Flink 1.14.2 for Scala 2.11版本
2.上傳至服務器并解壓檔案
tar -xvf flink-1.14.2-bin-scala_2.11.tgz3.啟動Flink
cd $FLINK_HOME
./bin/start-cluster.sh Starting cluster進入flink下bin目錄執行start-cluster.sh腳本啟動Flink(暫不用修改配置)
二、初體驗
1.在瀏覽器鍵入http://ip:8081 進入Flink Web UI
2.在Flink 1.14.2 二進制發布包中官方已經提供了部分demo供用戶測驗和體驗，我們可以在flink目錄下examples中找到，本次體驗使用經典、簡單的WordCount.jar
3.運行測驗示例
cd $FLINK_HOME
/bin/flink run ./examples/streaming/WordCount.jar4.檢查Flink Web UI "Job -> Runing Jobs"中的作業
5.如果應用是流式的,它會一直運行下去,直到你手動取消，取消的方式是在UI中選定作業，然后點擊Cancel按鈕，
6.如果作業是批量的，在作業結束后作業狀態更改為FINISHED，可以在Flink Web UI "Job -> Completed Jobs"中查看，
7.關閉Flink服務
cd $FLINK_HOME
./bin/stop-cluster.sh未完待續...
轉載請註明出處，本文鏈接：https://www.uj5u.com/qita/416187.html
標籤：其他
上一篇：關于kafka資料丟失場景的一次激烈討論.... |文末送書
下一篇：3分鐘搞懂中臺