在Flink中进行远程调试

问题描述

在flink-conf.yaml中添加了一个参数：

env.java.opts.taskmanager: "-agentlib:jdwp=transport=dt_socket,server=y,suspend=y,address=51005"

然后我在本地主机上使用以下命令启动了一个作业管理器和一个任务管理器：

flink-1.9.1_bin/bin/jobmanager.sh start
flink-1.9.1_bin/bin/taskmanager.sh start

Jobmanager运行，我可以在localhost：8081上看到flink UI仪表板。 Taskmanager等待51001端口上的连接。在我从IDE（IntelliJ）调试我的代码后运行，该代码已在localhost：51001上进行了远程调试。从IDE开始调试时，可以看到添加了任务插槽。在此之后，我运行以下命令：

flink-1.9.1_bin/bin/flink run -c myapp.Main myapp.jar

我希望调试点能进入我在IDE中的本地代码，但不会出现。我的代码可以直接进入运行状态，而我可以在flink UI仪表板上。

我可以对普通的Java项目进行远程调试，而对于flink作业则不能。

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）