Flink1.10.1集成Hadoop3.0.0源码编译实战

Flink1.10.1集成Hadoop3.0.0源码编译实战 前言

flink1.8以后不再提供对hadoop的支持，对比flink1.7与 flink1.8

官方仅提供几个hadoop版本对应的包，如果没有您需要版本，需自行编译

编译

下载另一个项目flink-shaded

git clone -b release-9.0 https://github.com/apache/flink-shaded.git

注意：这里一定要使用9.0，因为flink-1.10.1项目中依赖的为9.0

mvn clean install -Dhadoop.version=3.0.0