flink stream 終於上local 集羣 運行起來

先上圖 運行界面

運行了三個任務

第一個是word count

第二三個是 數據 producer and  consumer ----> 更多代碼 能夠參考上一篇blog 裏面有很詳細的介紹

在數據從idea 導出jar 包 已經 運行的過程當中遇到兩個問題

 

1，導出時候 由於是單機環境 須要把 kafka 等相關的依賴 一塊兒導出 

參考這個blog  ，主要是要勾選 include in project build 該項 ，thanks

 https://www.cnblogs.com/ALittleMoreLove/archive/2018/08/09/9449992.html

 

2， 另外一個錯誤是沒有足夠的 slots  ，這個從overview 中找到 ，須要修改 flink-conf.yaml 文件中的 taskmanager.numberoftaskslots = 8 ,默認是 1  （咱們起的任務大於1 了 因此 形成失敗）

具體能夠參考這個blog thanks 

http://www.javashuo.com/article/p-eplarbkk-ge.html

 

尼泊爾 珠峯大本營 ，以及昆布冰川