Flink(一)：flink源码&&导入到IDE

一、获取源码

1、从 Git 克隆代码

git clone https://github.com/apache/flink.git

2、maven运行编译

mvn clean install -DskipTests

注：为了加速构建，可以执行如下命令，以跳过测试，QA 的插件和 JavaDocs 的生成：

mvn clean install -DskipTests -Dfast

二、环境

1、JDK8

运行单元测试需要 Java 8u51 以上的版本，以避免使用 PowerMock Runner 的单元测试失败。

2、maven3

*注意：Maven 3.3.x 可以构建 Flink，但是不能正确地屏蔽掉指定的依赖。Maven 3.2.5 可以正确地构建库文件。

三、导入到IDE

1、安装Scala插件：IntelliJ 提供了插件设置来安装 Scala 插件：

1）转到 IntelliJ Settings → Plugins 并选择 “Marketplace”。

2）选择安装“Scala”插件。

3）如果出现提示，请重启IntelliJ

2、导入Flink项目

1）启动 IntelliJ IDEA 并选择 New → Project from Existing Sources。

2）选择已克隆的 Flink 存储库的根文件夹。
3）选择 “Import project from external model”，然后选择 “Maven”。
4）保留默认选项，然后依次单击 “Next”，直到到达 SDK 部分。
5）如果未列出 SDK，请使用左上角的 “+” 号创建一个。选择 “JDK”，选择 JDK 主目录，然后单击 “OK”。选择最合适的 JDK 版本。注意：一个好的经验法则是选择与活动 Maven 配置文件匹 配的 JDK 版本。
6）单击 “Next” 继续，直到完成导入。
7）右键单击已导入的 Flink 项目 → Maven → Generate Sources and Update Folders。请注意：这会将 Flink 库安装在本地 Maven 存储库中，默认情况下位于 “/home/$USER/.m2/repository/org/apache/flink/“。另外 mvn clean package -DskipTests 也可以创建 IDE 运行所需的文件，但无需安装库。
8）编译项目（Build → Make Project）。