IDEA(1):idae 對Flink 集群進行遠程調試

0 前言

flink 集群部署在linux服務器上，idea在windows電腦端

1 集群設置

1）文件flink-conf.yaml
添加兩行

# jobmanager debug端口
env.java.opts.jobmanager: "-agentlib:jdwp=transport=dt_socket,server=y,suspend=n,address=5006"
# # taskmanager debug端口
env.java.opts.taskmanager: "-agentlib:jdwp=transport=dt_socket,server=y,suspend=n,address=5005"

2）啟動集群

2 idea設置

1） 點擊Run–>Edit Configuration–> + -->Remote完成遠程調試的配置。

 

 2）

 

 

 

3）:
  在JobMaster.java類中打上斷點，並點擊Debug(注意選擇之前配置好的遠程調試)。

 

4) 調試運行

 

 5）調試運行成功標識

3 向flink提交任務