flinkFlink 使用IntelliJ IDEA 进行远程调试代码

Posted 2021-09-03 九师兄

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了flinkFlink 使用IntelliJ IDEA 进行远程调试代码相关的知识，希望对你有一定的参考价值。

1.概述

转载：Flink 使用IntelliJ IDEA 进行远程调试代码

Flink on Yarn 不好调试, 所以需要用到远程调试.

注意 : 开启远程调试的代码,必须与本地idea的代码必须保持一致.

二 .服务器端配置.

2.1. 设置启动远程debug端口

修改服务器上的配置文件 ${FLINK_HOME}/flink-config.yaml 增加环境变量即可.

参考的设置

组件	环境变量设置
Client	env.java.opts.client: -agentlib:jdwp=transport=dt_socket,server=y,suspend=y,address=5666
JobManager	env.java.opts.jobmanager: -agentlib:jdwp=transport=dt_socket,server=y,suspend=y,address=5005
TaskManager	env.java.opts.taskmanager: -agentlib:jdwp=transport=dt_socket,server=y,suspend=y,address=5006

2.2. 具体操作

编辑服务器上的配置文件[ ${FLINK_HOME}/flink-config.yaml 随便加上一行[记住端口!!!]:


# jobmanager debug端口
env.java.opts.jobmanager: -agentlib:jdwp=transport=dt_socket,server=y,suspend=y,address=5005

# taskmanager debug端口
env.java.opts.taskmanager: -agentlib:jdwp=transport=dt_socket,server=y,suspend=y,address=5006

suspend : 是否阻塞, 如果是调试启动的话, 建议设置成 y .
address : 调试的远程端口 5005

调试JobManager的话,要注意设置一下超时时间.

修改配置文件[ ${FLINK_HOME}/flink-config.yaml 增加一行代码:

# 设置超时 时间 . 单位 毫秒.
rest.connection-timeout: 360000000
rest.idleness-timeout: 360000000

启动服务即可 [启动完, JVM返现有jdwp的配置,会自动阻塞, 等到idea调试连接.].
因为我要调试的是JobManager .
所以启动命令为:

cd ${FLINK_HOME}/bin


# 启动任务

flink run -t yarn-per-job -c org.apache.flink.streaming.examples.socket.SocketWindowWordCount examples/streaming/SocketWindowWordCount.jar --port 9999