hello, 

??flink ????????????1.14.0?????? ????maven 3.2.5 ??????????


1. ?????????? mvn clean install -DskipTests -Dfast


2. ??flink-1.14.0/flink-dist/target/flink-1.14.0-bin/  ??????????????????


3. ???? conf/flink-conf.yaml
    ??????env.java.opts: 
"-agentlib:jdwp=transport=dt_socket,server=y,suspend=y,address=5003"


4. ??????????????????idea(windows ????)?? ??????Remote ??????
    Trantsport: Socket 
    Host:   xxx.xxx.xx.xx          
 Port: 5003


5. ??????????????yarn-per-job ??????
    bin/flink run -t yarn-per-job -c 
org.apache.flink.streaming.examples.socket.SocketWindowWordCount 
examples/streaming/SocketWindowWordCount.jar --hostname xxx.xxx.xx.xx --port 
9999


6. ??idea ??????debug


??????????????debug flink yarn-per-job 
????????????jobmanager??????????????YarnJobClusterEntrypoint ???? 
main???????????????????? 
        ??????YarnJobClusterEntrypoint ????debug?

回复