1.git 下載源碼
git clone?https://github.com/apache/flink.git
公司目前使用的是1.5.0版本备禀,所以切換到release-1.5.0
git checkout release-1.5.0
2.導(dǎo)入IDE
ItelliJ IDEA-> open
導(dǎo)入之后算墨,Profile不要選(感覺會有這個紅色xx)滨嘱,maven配置公司的倉庫寺晌,或者外網(wǎng)阿里云,在~/.m2/setting.xml文件里面
3.編譯
使用命令 mvn clean install -Dmaven.test.skip=true
3.1?com.mapr.hadoop:maprfs:5.2.1-mapr找不到
編譯之后类早,會出現(xiàn)各種錯誤掂名,首先碰到flink-mapr-fs模塊下面的依賴jar包com.mapr.hadoop:maprfs:5.2.1-mapr找不到。
下載地址:
https://repository.mapr.com/nexus/content/groups/mapr-public/com/mapr/hadoop/maprfs/5.2.1-mapr/maprfs-5.2.1-mapr.jar?
執(zhí)行命令:
mvn install:install-file -DgroupId=com.mapr.hadoop -DartifactId=maprfs -Dversion=5.2.1-mapr -Dpackaging=jar -Dfile=maprfs-5.2.1-mapr.jar
導(dǎo)入本地倉庫
重新執(zhí)行
mvn clean install -Dmaven.test.skip=true -rf :flink-mapr-fs
會跳過前面捶牢,直接從flink-mapr-fs模塊開始
3.2?mapr包下面的org.apache.hadoop.fs找不到
按道理不會找不到鸠珠,但是報錯,把依賴添加進(jìn)去秋麸。
flink-filesystems/flink-mapr-fs/pom.xml里面添加依賴
<dependency>
<groupId>org.apache.hadoop</groupId>
<artifactId>hadoop-common</artifactId>
<version>${hadoop.version}</version>
</dependency>
3.3 kafka-schema-registry-client-3.3.1.jar找不到
下載地址
http://packages.confluent.io/maven/io/confluent/kafka-schema-registry-client/3.3.1/kafka-schema-registry-client-3.3.1.jar
執(zhí)行命令
mvn install:install-file -DgroupId=io.confluent -DartifactId=kafka-schema-registry-client -Dversion=3.3.1 -Dpackaging=jar -Dfile=kafka-schema-registry-client-3.3.1.jar
導(dǎo)入本地倉庫
重新執(zhí)行