默認準(zhǔn)備好相應(yīng)的環(huán)境
- IDEA (包含Scala插件等環(huán)境)
- 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源碼導(dǎo)入到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相關(guān)配置
配置Remote
4.1
4.2
4.3
要使用遠程調(diào)試覆获，我們需要添加一段jvm啟動參數(shù)帚稠，這個參數(shù)如下：
agentlib:jdwp=transport=dt_socket,server=y,suspend=n,address=5005
調(diào)試操作
4.4
