我想在开发期间将作业部署在本地 Flink 集群上(即在我的开发笔记本电脑上运行的 JobManager 和 TaskManager(,并使用远程调试。我尝试添加 "-agentlib:jdwp=transport=dt_socket,server=y,suspend=y,address=5005"到 flink-conf.yaml 文件中。由于作业和任务管理器在同一台计算机上运行,因此任务管理器会抛出异常,指出套接字已在使用中并终止。有什么办法可以让它运行。
你可能正在设置env.java.opts
,这会影响Flink启动的所有JVM。由于作业管理器首先启动,因此它会在任务管理器启动之前获取端口。
您可以使用env.java.opts.taskmanager
仅传递任务管理器 JVM 的参数。