FLINK源代码调试方式

Posted 2021-01-16 163yun

此文已由作者岳猛授权网易云社区发布。

欢迎访问网易云社区，了解更多网易技术产品运营经验。

第一种，直接通过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测试