1、下载源码(本地安装有git环境)
git clone https://gitee.com/apache/flink.git
git checkout release-1.10.0
#注意1.10.0是tag版本
2、mvn构建时会有异常:Could not find artifact io.confluent:kafka-schema-registry-client:pom:3.3.1 in aliyunmaven (https://maven.aliyun.com/repository/public)
下载 http://packages.confluent.io/maven/io/confluent/kafka-schema-registry-client/3.3.1/kafka-schema-registry-client-3.3.1.jar
mvn install:install-file -DgroupId=io.confluent -DartifactId=kafka-schema-registry-client -Dversion=3.3.1 -Dpackaging=jar -Dfile=D:\\kafka-schema-registry-client\\kafka-schema-registry-client-3.3.1.jar
3、开始构建
mvn clean install -DskipTests -Dfast -Drat.skip=true -Dhaoop.version=2.8.3 -Pvendor-repos -Dinclude-hadoop -Dscala-2.11
说明:指定Hadoop的版本 haoop.version=2.8.3