-
配置⽂件修改:
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
