1. 程式人生 > >FLINK源代碼調試方式

FLINK源代碼調試方式

采集 連接 經驗 設置 源代碼 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-5324

    2 如果是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源代碼調試方式