前置要求
- Java技术体系
- Git版本管理使用
- Maven依赖管理使用(官方建议使用版本3.2.5)
- Idea软件使用
源码下载与Idea配置
新建一个名为 flink-in-depth 的目录
使用cd命令进入到这个目录下，然后下载Flink的master分支源码
mkdir flink-in-depth
cd flink-in-depth
git clone https://github.com/apache/flink.git
源码下载完毕后，我们使用Idea打开 flink-in-depth 目录，即 flink 源码目录的上层目录
我们不用急着在Idea中导入源码，先进行一番配置也不迟
由于我们是想成为Flink源码核心的Contributor，所以我们是不需要对Flink源码目录下的所有子模块进行编译与处理的
这里我们移除 flink-end-to-end-tests、flink-fs-tests、flink-yarn-tests 顶层子模块，以及 flink-connectors、flink-filesystems、flink-fromats、flink-architecture-tests、flink-examples、flink-dist 下的部分子模块
打开 Flink 下的顶层pom.xml，移除 flink-end-to-end-tests、flink-fs-tests、flink-yarn-tests
移除 flink-connectors 下的部分子模块，我们暂时就只保留 jdbc、kafka、hive、file 这些connector模块吧
同理 flink-filesystems、flink-formats、flink-architecture-tests、flink-examples、flink-dist 的相应子模块也需要移除，具体可以参考笔者的专用 github 地址
https://github.com/coderappee/flink-in-depth.git
https://github.com/coderappee/flink.git
其中 flink-architecture-tests 在移除子模块时，在 flink-architecture-tests 顶层pom里也把相应的connectors依赖去除
flink-dist 中需要把相应的 flink-filesystems 里依赖的模块移除掉，在进行 assembly 打包里也需要把相应移除的模块移除掉
移除这些模块，除了加快编译外，主要还是减少对我们Flink源码核心开发的影响，这些都是扩展模块，对源码核心的开发是帮助不大的，后续我们在合并原Flink的repo代码时可以通过不合并或解决冲突的方式，不把我们对这些模块移除的修改合并到本地的相应的issue分支里
除了移除模块，有时我们还看到Flink进行版本升级时，PMC或Committer会批量的升级Flink的版本
具体做法是打开idea的 run/debug configuration，并新建三条 maven 执行命令，我们就暂时把我们的版本命名为custom-test吧
用于对版本批量重命名:
mvn versions:set -DnewVersion=custom-test
用于对版本批量重命名后提交:
mvn versions:commit
用于对版本批量重命名后回滚
mvn versions:revert
我们对自己的Flink版本进行批量重命名并提交之后就可以看到已经把没有移除模块的所有pom.xml的版本都命名为custom-test了
由于笔者自己本地系统所持有的hadoop版本是2.7.3，所以笔者也把顶层的hadoop依赖修改为2.7.3，这点读者朋友们根据自己所持有的hadoop版本进行相应修改
进行完上述修改后，我们也相应的把自己修改后的Flink版本给建个git分支，就叫做custom-test分支吧
使用Idea的Maven功能导入源码并编译源码
现在我们就可以使用Idea导入自建Flink版本源码了
然后新建maven命名并进行构建
mvn clean install -DskipTests -Dfast -Dhadoop.version=2.7.3
构建完成后就可以进行Flink源码的核心开发与调试
可以看到构建完后在Flink源码的根目录下出现build-target，这就是我们平时从官网下载的发行版本的目录结构
我们可以基于build-target目录进行Flink应用的部署与提交，相应的命令也在bin目录里
原文出处：
CodeRap的Gitee博客
CodeRap的Github博客
欢迎关注我的公众号：coderap_blog
