实际生产环境中一般使用基于CDH的大数据软件组件,因此Flink也会选择这些组件,但是由于CDH版本的软件并没有对应Flink的安装包,所以需要对开源的Flink进行重新编译,然后再用于适配对应CDH版本的Hadoop。
1.准备工作
安装Maven 3或以上版本;安装JDK 1.8;所需系统为Linux。
2.下载Flink源码包并进行编译
开启Linux服务器,执行以下命令来下载Flink的源码包,并使用Maven进行编译。
编译成功后的文件夹位于: