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

发布时间 2023-11-09 13:21:55作者: renxiaoren

一、获取源码

  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)。