默认准备好相应的环境
- 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
