默认准备好相应的环境

• IDEA (包含Scala插件等环境)
• Java 1.8.0_131
• Scala 11.8
• Maven 3.6.0
• git 2.14.1 和 git desktop客户端

步骤

步骤一：从github中下载flink源码

1. 1 使用命令行下载

git clone git@github.com:yeoggc/flink-1.9.3-ggc-src.git

1.2 使用github的desktop下载

推荐：使用github的desktop来下载flink源码，亲测速度非常的快!

step1 step2

步骤二：flink源码导入到idea

步骤三：配置conf/flink-conf.yaml文件

3.1 standlone模式

首先在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

然后启动集群
./start-cluster.sh

3.2 yarn模式

//TODO  待补充

步骤四：IDEA相关配置

配置Remote

4.1 4.2 4.3

要使用远程调试，我们需要添加一段jvm启动参数，这个参数如下：

agentlib:jdwp=transport=dt_socket,server=y,suspend=n,address=5005

调试操作

4.4