Flink-1.12.0/1.14.3-CDH6.3.2源码编译、CDH-Flink-Parcel制作、CDH6.3.2集成Flink1.12.0/1.14.3

本文主要是介绍Flink-1.12.0/1.14.3-CDH6.3.2源码编译、CDH-Flink-Parcel制作、CDH6.3.2集成Flink1.12.0/1.14.3，对大家解决编程问题具有一定的参考价值，需要的程序猿们随着小编来一起学习吧！

**自己编译的Flink源码，并制作相应的parcel，已完成flink1.12和最新flink版本1.14.3.**如果不想自己编译，可以使用我编译和制作好的parcel文件。亲测可用。可以参考我另一篇文章，下载！

flink-parcel制作过程

以CDH6.3.2、FLINK1.9.1为例

(1)下载制作包

git clone https://github.com/pkeropen/flink-parcel.git
(2)修改配置文件　flink-parcel.properties

#FLINK 下载地址
#FLINK_URL=https://archive.apache.org/dist/flink/flink-1.14.3/flink-1.14.3-bin-scala_2.12.tgz
FLINK_URL=https://archive.apache.org/dist/flink/flink-1.12.0/flink-1.12.0-bin-scala_2.11.tgz
#flink版本号
FLINK_VERSION=1.12.0

#扩展版本号
EXTENS_VERSION=BIN-SCALA_2.12

#操作系统版本，以centos为例
OS_VERSION=7

#CDH 小版本
CDH_MIN_FULL=5.2
CDH_MAX_FULL=6.3.2

#CDH大版本
CDH_MIN=5
CDH_MAX=6

(2)生成parcel文件

./build.sh parcel
(3)生成csd文件

on yarn 版本
./build.sh csd_on_yarn
standalone版本
./build.sh csd_standalone
CDH 中安装flink服务

此处假设你已经安装好CDH集群

(1) 将上面生成的parcel文件copy至 cloudera/parcel-repo子目录下

(2) 将上述生成的jar文件copy至cloudera /parcel-repo子目录下

(3) 在CDH中添加flink的parcel包：

打开CDH管理界面->集群->检查parcel包->flink->分配->激活

(4) 重启CDH服务后 ，点击CDH所管理的集群添加服务，在列表中找到flink，按提示添加启动并运行。

制作好的文件截图。。。。

这篇关于Flink-1.12.0/1.14.3-CDH6.3.2源码编译、CDH-Flink-Parcel制作、CDH6.3.2集成Flink1.12.0/1.14.3的文章就介绍到这儿，希望我们推荐的文章对大家有所帮助，也希望大家多多支持为之网！