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提交任务
标签:Flink,java,flink,suspend,集群,idae,远程,调试 来源: https://www.cnblogs.com/qiu-hua/p/14711302.html