微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

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,按提示添加启动并运行。

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

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 [email protected] 举报,一经查实,本站将立刻删除。

相关推荐