Window环境下编译Flink1.10源码 _Flink1.10

导读：Apache Flink是一个框架和分布式处理引擎，用于对无边界和有边界的数据流进行有状态的计算。官方文档虽然很详细，但想对Flink进一步深入了解则需要阅读Flink的源码。本文主要讨论Flink源码获取编译，及可能会遇到的问题及解决方案。

文章插图

基本环境

至少JDK 8
Maven 3
Flink官网推荐工具使用 IDEA（下面内容均基于IDEA）

Flink源码拉取【Window环境下编译Flink1.10源码】//使用git从github拉取https://github.com/apache/flink/由于从GitHub拉取比较慢，解决的方式有多种。这里列举一种借助gitee的方式：
1、登录gitee -- 创建仓库 -- 导入已有仓库，耐心等待一段时间。

文章插图

2、将代码从gittee clone到本地。
下载安装 Scala 插件因Flink具有用scala编写的API，因需要配置Scala插件及Scala SDK 。
配置Scala IDEA插件：File -- Settings -- Plugins -- Maketplace -- 搜索Scala -- install

文章插图

下载并配置Scala SDKhttps://www.scala-lang.org/download///从官网下载scala的SDK

文章插图

配置Scala SDK：File -- Project Structure -- Platform Settings -- Global Libraries -- +号 -- 选择Scala SDK

文章插图

这里选择Brown--指定刚下好Scala SDK 目录（解压）

文章插图

执行编译命令mvn clean install -DskipTests -Drat.skip=true可能会遇到的问题及解决方案问题1：由于flink-runtime-web模块引入了frontend-maven-plugin依赖，并安装了node和部分依赖组件，会因网络原因导致 [ERROR] Failed to execute goal com.github.eirslett:frontend-maven-plugin:1.6:install-node-and-npm (install node and npm)
解决方式：

//修改 flink-runtime-web 的 pom,xml 文件镜像为淘宝镜像<nodeDownloadRoot>http://npm.taobao.org/mirrors/node/</nodeDownloadRoot><npmDownloadRoot>http://npm.taobao.org/mirrors/npm/</npmDownloadRoot>

文章插图

问题2：Could not resolve dependencies for project org.apache.flink:flink-avro-confluent-registry:jar:1.6.2:
解决方式：

//1、下载kafka-schema-registry-client-4.1.0.jar http://packages.confluent.io/maven/io/confluent/kafka-schema-registry-client/4.1.0/kafka-schema-registry-client-4.1.0.jar //2、手动安装mvn install:install-file -DgroupId=io.confluent -DartifactId=kafka-schema-registry-client -Dversion=4.1.0 -Dpackaging=jar-Dfile=你所存放的目录/kafka-schema-registry-client-4.1.0.jar//3、继续编译mvn clean install -DskipTests -Drat.skip=true -rf :flink-avro-confluent-registry

编译完成