Flink 搭建單機環境

搭建乙個單機版的執行環境

環境：ubuntu 18

啟動完成後，開啟localhost:8081可看到webui

同時在log目錄下，會生成對應日誌

可通過這個檢視

例如：tail log/flink-root-standalonesession-0-donald-pro.log

參考官網教程：

linux nc命令用於設定路由器。

命令相關可檢視：

檢視輸出結果

socketwindowwordcount應用程式根據處理時間開滾動視窗，每秒計算一次視窗接收單詞的次數

object socketwindowwordcount  catch 

}// get the execution environment
val env: streamexecutionenvironment = streamexecutionenvironment.getexecutionenvironment
// get input data by connecting to the socket
val text = env.sockettextstream("localhost", port, '\n')
// parse the data, group it, window it, and aggregate the counts
val windowcounts = text
.flatmap 
.map 
.keyby("word")
.timewindow(time.seconds(5), time.seconds(1)) // 
.sum("count")
// print the results with a single thread, rather than in parallel
windowcounts.print().setparallelism(1)
env.execute("socket window wordcount")
}// data type for words with count
case class wordwithcount(word: string, count: long)
}

如果應用程式的時間特徵為事件時間，則開長度為5秒的事件時間視窗，否則開長度位1秒的處理時間視窗

mvn archetype:generate \

-darchetypegroupid=org.apache.flink \
-darchetypeartifactid=flink-quickstart-scala \
-darchetypeversion=1.8.0 \
-dgroupid=com.deepmind.flink \
-dartifactid=quickstart \
-dversion="1.0-snapshot" \
-dinteractivemode=false; # 設定為batch模式
該工程有兩個案例，分別為：
批處理應用程式batchjob流處理應用程式streamingjob
 
Flink 環境搭建
在 2.1 節中已經將 flink 的準備環境已經講完了，本篇文章將帶大家正式開始接觸 flink，那麼我們得先安裝一下 flink。flink 是可以在多個平台 windows linux mac 上安裝的。在開始寫本書的時候最新版本是 1.8 版本，但是寫到一半後更新到 1.9 了 合併了大量 ...
redis單機環境搭建
解壓 tar xvf redis 3.2.9.tar.gz 進入該目錄 cd redis 3.2.9 安裝 make 不指定安裝位置，則會把可執行檔案安裝到redis 3.2.9 src目錄下 make install prefix usr local redis 啟動 redis server s...
Eureka單機環境搭建
這是在現有的父工程下引入的包 首先需要引入spring的一些功能包 org.springframework.cloud groupid spring cloud starter netflix eureka server artifactid dependency server port 服務埠 s...