這篇文章主要介紹“怎么在IDEA上運行Flink任務”，在日常操作中，相信很多人在怎么在IDEA上運行Flink任務問題上存在疑惑，小編查閱了各式資料，整理出簡單好用的操作方法，希望對大家解答”怎么在IDEA上運行Flink任務”的疑惑有所幫助！接下來，請跟著小編一起來學習吧！

成都創(chuàng)新互聯是專業(yè)的河東網站建設公司，河東接單;提供成都做網站、成都網站建設,網頁設計,網站設計,建網站,PHP網站建設等專業(yè)做網站服務;采用PHP框架,可快速的進行河東網站開發(fā)網頁制作和功能擴展;專業(yè)做搜索引擎喜愛的網站,專業(yè)的做網站團隊,希望更多企業(yè)前來合作!

歡迎訪問我的GitHub

https://github.com/zq2599/blog_demos

內容：所有原創(chuàng)文章分類匯總及配套源碼，涉及Java、Docker、Kubernetes、DevOPS等；

IDEA是常用的IDE，我們編寫的flink任務代碼如果能直接在IDEA運行，會給學習和開發(fā)帶來很大便利，例如改完代碼立即運行不用部署、斷點、單步調試等；

環(huán)境信息

1. 電腦：2019版13寸MacBook Pro，2.3 GHz 四核Intel Core i5，8 GB 2133 MHz LPDDR3

2. 操作系統：macOS Catalina 10.15.3

3. JDK：1.8.0_211

4. Maven：3.6.0

5. IDEA：2018.3.5 (Ultimate Edition)

6. Flink版本：1.9.2

關于正版IDEA

如何免費使用正版IDEA，可以參考《免費申請和使用IntelliJ IDEA商業(yè)版License指南》

開發(fā)

1. 首先確保您電腦上maven已裝好；

2. 創(chuàng)建一個flink任務的maven工程，找個干凈目錄執(zhí)行以下命令：

mvn \
archetype:generate \
-DarchetypeGroupId=org.apache.flink \
-DarchetypeArtifactId=flink-quickstart-java \
-DarchetypeVersion=1.9.2

3. 按提示輸入groupId、artifactId、version、package等內容：

4. 現在maven工程已生成，用IDEA導入這個工程，如下圖：

5. 以maven的類型導入：

6. 導入成功后的樣子：

7. 修改<font color="blue">StreamingJob.java</font>，加入功能是監(jiān)聽本地<font color="blue">18081</font>端口，得到的字符串做word count操作，完整代碼在此下載：https://raw.githubusercontent.com/zq2599/blog_demos/master/files/StreamingJob.java

8. 現在的代碼已經能運行，但flink網頁卻還不能訪問，會顯示以下錯誤信息，需要繼續(xù)做些設置：

9. 下載flink-1.9.2安裝包，這里面有flink網頁服務用到的一個jar，地址是：https://www-eu.apache.org/dist/flink/flink-1.9.2/flink-1.9.2-bin-scala_2.11.tgz 10. <font color="blue">flink-1.9.2-bin-scala_2.11.tgz</font>下載后解壓，在lib目錄下有個<font color="blue">flink-dist_2.11-1.9.2.jar</font>文件，記住此文件的位置，稍后會用到； 11. 回到IDEA，在項目上點擊右鍵，點擊菜單<font color="blue">Open Module Settings</font>：

12. 在彈出的窗口做如下操作，目的是給項目中增加jar：

13. 彈出選擇文件的窗口，請選擇剛才準備好的文件<font color="blue">flink-dist_2.11-1.9.2.jar</font>：

14. 設置工作已經完成，由于StreamingJob的工作是讀取本機18081端口的數據，所以我們要把18081端口的服務啟動起來，不然StreamingJob運行時是連不上端口的，打開一個控制臺，執(zhí)行命令：<font color="blue">nc -l 18081</font> 15. 現在可以將StreamingJob運行起來，如下圖，右鍵點擊StreamingJob，選擇<font color="blue">Run 'StreamingJob.main()'：</font>即可啟動flink任務，如果想打斷點調試，請選擇<font color="blue">Debug 'StreamingJob.main()'</font>

16. 回到剛才執(zhí)行nc命令的控制臺，輸入一些字符串，例如"aaa bbb aaa"，然后回車； 17. 再回到IDEA，可見StreamingJob已經從18081端口讀到了數據并且輸出了統計結果：

18. 在IDEA的控制臺搜索關鍵字<font color="blue">localhost</font>，如下圖紅框，可以查到flink網頁的端口，我這里是<font color="blue">62641</font>：

19. 瀏覽器訪問<font color="blue">http://localhost:62641</font>，如下圖，可見flink網頁已經正常顯示，正在運行的任務也能看到：

至此，最簡單的IDEA運行flink任務的實戰(zhàn)就完成了，如果您也在學習flink，希望本文能給您一些參考；

到此，關于“怎么在IDEA上運行Flink任務”的學習就結束了，希望能夠解決大家的疑惑。理論與實踐的搭配能更好的幫助大家學習，快去試試吧！若想繼續(xù)學習更多相關知識，請繼續(xù)關注創(chuàng)新互聯網站，小編會繼續(xù)努力為大家?guī)砀鄬嵱玫奈恼拢?/p>

當前文章：怎么在IDEA上運行Flink任務
文章起源：http://jinyejixie.com/article4/pggsie.html

成都網站建設公司_創(chuàng)新互聯，為您提供電子商務、虛擬主機、做網站、關鍵詞優(yōu)化、小程序開發(fā)、ChatGPT

廣告

聲明：本網站發(fā)布的內容（圖片、視頻和文字）以用戶投稿、用戶轉載內容為主，如果涉及侵權請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網站立場，如需處理請聯系客服。電話：028-86922220；郵箱：631063699@qq.com。內容未經允許不得轉載，或轉載時需注明來源： 創(chuàng)新互聯