导读：在学习或者使用各个大数据框架的时候，往往想对runtime层次的代码进行调试或者跟踪阅读，但其往往部署在其他机器上，因此需要进行远程调试。本文以Flink为例，介绍如何通过IDEA进行Flink的runtime层次的远程调试。
环境：
Flink1.4.2
IntelliJ IDEA
虚拟机模拟的Flink集群
先对Flink的作业提交过程进行简单介绍(以批处理为例)：
用户写完的代码，会被转化为plan，之后plan会被优化成OptimizedPlan，并转化成JobGraph，得到JobGraph后，Client会将JobGraph提交给JobManager，由JobManager将JobGraph转化为ExecutionGraph，之后再ExecutionGraph中的各个Task部署到各个slave上，进行计算。过程为：
Plan–>OptimizedPlan–>JobGraph–>ExecutionGraph–>执行
其中Plan到生成JobGraph都是Client端完成的，之后则是JobManager和TaskManager完成的。
具体如下图所示：
接下来以调试JobManager为例，介绍详细步骤：
step1:
在flink/bin目录下的jobmanager.sh脚本中，添加：
export JVM_ARGS="-agentlib:jdwp=transport=dt_socket,server=y,suspend=n,address=5005"
其中suspend=n用于设置是否阻塞，address用于设置端口。
step2:
通过bin/start-cluster.sh启动flink集群。
step3：
在IDEA中设置远程调试：
点击Run–>Edit Configuration–> + –>Remote完成远程调试的配置。
step4:
在JobManager.scala类中打上断点，并点击Debug(注意选择之前配置好的远程调试)。
点击后会出现如下界面，等待连接：
step5:
在集群中通过flink run进行任务的提交。
step6:
大功告成！
PS：由于runtime层经常会有多线程之类的，可能在打断点的时候，需要选择Thread模式，如下图：
具体还是多实践吧~！