flink中的java远程调试

llycmphe  于 2021-06-21  发布在  Flink
关注(0)|答案(0)|浏览(575)

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

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

然后,我在localhost上使用以下命令启动了一个jobmanager和一个taskmanager:

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

jobmanager运行时,我可以看到flinkui Jmeter 板localhost:8081. taskmanager正在51001端口上等待连接。它在我从ide(intellij)调试代码之后运行,ide上有远程调试的设置localhost:51001. 当我从ide开始调试时,我可以看到已经添加了任务。之后,我运行以下命令:

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

我希望调试点会出现在ide中的本地代码中,但它不会出现。我的代码直接进入运行状态,我可以在flinkui Jmeter 板中运行。
我可以为普通java项目进行远程调试,但不能为flink作业进行远程调试。

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题