一：远程调试
    在flink-conf.yaml中添加:
    env.java.opts.jobmanager: -agentlib:jdwp=transport=dt_socket,server=y,suspend=y,address=5005
    env.java.opts.taskmanager: -agentlib:jdwp=transport=dt_socket,server=y,suspend=y,address=5006
    ————————————————-

    Yarn集群jobmanager 入口：YarnJobClusterEntrypoint
    集群taskmanager 监听入口：TaskManagerRunner

    二：本地启动 standalone cluster模式，
    jobmanager的入口类是org.apache.flink.runtime.entrypoint.StandaloneSessionClusterEntrypoint,
    taskmanager的入口类是org.apache.flink.runtime.taskexecutor.TaskManagerRunner,
    找到main方法打上断点就可以开始调试了。

    三：编译flink

    mvn clean install -T 2C -Dfast -Dmaven.compile.fork=true -DskipTests -Dscala-2.11 -Pinclude-hadoop -Dhadoop.version=2.7.5