在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作业进行远程调试。
暂无答案!
目前还没有任何答案,快来回答吧!