我希望在开发期间将作业部署到本地Flink集群上(即在我的开发笔记本电脑上运行的JobManager和TaskManager ),并使用远程调试。我尝试在flink-conf.yaml文件中添加"-agentlib:jdwp=transport=dt_socket,server=y,suspend=y,address=5005“。由于作业和任务管理器在同一台机器上运行,因此任务管理器抛出异常,声明套接字已在使用中并终止。有没有什么办法可以让它运行起来。
发布于 2018-05-02 04:46:35
您可能正在设置env.java.opts
,这会影响由Flink启动的所有JVM。因为作业管理器首先启动,所以它在任务管理器启动之前获取端口。
您可以使用env.java.opts.taskmanager
仅为taskmanager JVM传递参数。
https://stackoverflow.com/questions/50125340
复制相似问题