Flink On YARN 远程 debug

  • 配置⽂件修改:
    flink-conf.yaml

    # jobmanager debug端⼝
    env.java.opts.jobmanager: "-
    agentlib:jdwp=transport=dt_socket,server=y,suspend=n,address=5006"
    # taskmanager debug端⼝
    env.java.opts.taskmanager: "-
    agentlib:jdwp=transport=dt_socket,server=y,suspend=n,address=5005"
    # 设置cliFrontend 客户端的debug端⼝
    env.java.opts.client: "-
    agentlib:jdwp=transport=dt_socket,server=y,suspend=y,address=5008"
    # 设置超时 时间 . 单位 毫秒.
    rest.connection-timeout: 360000000
    rest.idleness-timeout: 360000000
    
  • 客户端提交

    bin/flink run -m yarn-cluster -d -ys 2 -p 1 -ytm 2g examples/streaming/StateMachineExample.jar
    
  • IDEA 配置 remote debug

请使用浏览器的分享功能分享到微信等