FLINK源代碼調試方式
阿新 • • 發佈:2018-10-31
采集 連接 經驗 設置 源代碼 streaming href ima -i
此文已由作者嶽猛授權網易雲社區發布。
歡迎訪問網易雲社區,了解更多網易技術產品運營經驗。
第一種,直接通過IDEA WINDOWS調試
前提是Flink所有依賴已經導入,直接在Test中打斷點,然後直接Debug。
第二種,遠程調試
1 設置DEBUG時候啟動的jvm調試參數
1.如果是yarn的模式直接在conf/flink-conf.yaml 目錄下添加
"env.java.opts: "-agentlib:jdwp=transport=dt_socket,server=y,suspend=y,address=9098"
但是這裏有bug,詳情請看FLINK-53242 如果是local模式或者standalone,可以直接在conf/config.sh添加export JVM_ARGS="-agentlib:jdwp=transport=dt_socket,server=y,suspend=y,address=9098"
2 設置斷點
設置斷點
3 啟動應用
nc -lp 9099
bin/flink run examples/streaming/SocketWindowWordCount.jar --port 9099然後程序會卡住等待IDEA連接
-4 IDEA連接
客戶端連接
5 下面就可以進行調試了
鏈接:https://www.jianshu.com/p/07b4d59cb6df
免費體驗雲安全(易盾)內容安全、驗證碼等服務
更多網易技術、產品、運營經驗分享請點擊。
相關文章:
【推薦】 網易鄭棟:數據采集與分析的那些事——從數據埋點到AB測試
FLINK源代碼調試方式