jobmanager
修改conf/flink-conf.yaml配置文件,添加
env.java.opts.jobmanager: -agentlib:jdwp=transport=dt_socket,server=y,suspend=n,address=5005
taskmanager
修改conf/flink-conf.yaml配置文件,添加
env.java.opts.taskmanager: -agentlib:jdwp=transport=dt_socket,server=y,suspend=n,address=5006
sqlclient
修改bin/sql-client.sh,添加
JVM_REMOTE_DEBUG_ARGS='-agentlib:jdwp=transport=dt_socket,server=y,suspend=y,address=5007'
并修改启动命令为:
exec $JAVA_RUN $JVM_ARGS
$JVM_REMOTE_DEBUG_ARGS
"${log_setting[@]}" -classpath "`manglePathList "$CC_CLASSPATH:$INTERNAL_HADOOP_CLASSPATHS"`" org.apache.flink.client.cli.CliFrontend "$@"