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 "$@"
网友评论