美文网首页
Flink debug

Flink debug

作者: david9 | 来源:发表于2021-11-22 14:30 被阅读0次
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 "$@"

相关文章

网友评论

      本文标题:Flink debug

      本文链接:https://www.haomeiwen.com/subject/salbtrtx.html