此文已由作者岳猛授權(quán)網(wǎng)易云社區(qū)發(fā)布。

歡迎訪問(wèn)網(wǎng)易云社區(qū)，了解更多網(wǎng)易技術(shù)產(chǎn)品運(yùn)營(yíng)經(jīng)驗(yàn)。

第一種，直接通過(guò)IDEA WINDOWS調(diào)試

前提是Flink所有依賴已經(jīng)導(dǎo)入，直接在Test中打斷點(diǎn)，然后直接Debug。

第二種，遠(yuǎn)程調(diào)試

• 1 設(shè)置DEBUG時(shí)候啟動(dòng)的jvm調(diào)試參數(shù)
  1.如果是yarn的模式直接在conf/flink-conf.yaml 目錄下添加
  "env.java.opts: "-agentlib:jdwp=transport=dt_socket,server=y,suspend=y,address=9098"
  但是這里有bug，詳情請(qǐng)看FLINK-5324

  2?如果是local模式或者standalone，可以直接在conf/config.sh添加export?JVM_ARGS="-agentlib:jdwp=transport=dt_socket,server=y,suspend=y,address=9098"

• 2 設(shè)置斷點(diǎn)

設(shè)置斷點(diǎn)

• 3 啟動(dòng)應(yīng)用
  nc -lp 9099
  bin/flink run examples/streaming/SocketWindowWordCount.jar --port 9099

  ????然后程序會(huì)卡住等待IDEA連接

-4 IDEA連接

客戶端連接

• 5 下面就可以進(jìn)行調(diào)試了

• 
  

鏈接：https://www.jianshu.com/p/07b4d59cb6df

免費(fèi)體驗(yàn)云安全(易盾)內(nèi)容安全、驗(yàn)證碼等服務(wù)

更多網(wǎng)易技術(shù)、產(chǎn)品、運(yùn)營(yíng)經(jīng)驗(yàn)分享請(qǐng)點(diǎn)擊。

相關(guān)文章：
【推薦】?網(wǎng)易鄭棟：數(shù)據(jù)采集與分析的那些事——從數(shù)據(jù)埋點(diǎn)到AB測(cè)試

轉(zhuǎn)載于:https://www.cnblogs.com/163yun/p/9882126.html

總結(jié)

以上是生活随笔為你收集整理的FLINK源代码调试方式的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。