分享知识,分享快乐

0%

CDH 6.3.2 集成 flink 1.14.6

CDH 6.3.2 集成 flink 1.14.6

制作Flink的parcel包和csd文件

1. 下载制作脚本

1
2
3
# 克隆源码
git clone https://github.com/pkeropen/flink-parcel.git
cd flink-parcel

2 修改参数

vim flink-parcel.properties

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
#FLINK 下载地址
FLINK_URL=https://archive.apache.org/dist/flink/flink-1.14.6/flink-1.14.6-bin-scala_2.12.tgz

#flink版本号
FLINK_VERSION=1.14.6

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

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

#CDH 小版本
CDH_MIN_FULL=5.13.1
CDH_MAX_FULL=6.3.2

#CDH大版本
CDH_MIN=5
CDH_MAX=6

4 编译parcel

1
2
3
4
# 赋予执行权限
chmod +x ./build.sh
# 执行编译脚本
./build.sh parcel

编译完会在flink-parcel项目根目录下生成_build文件夹

5 编译csd

1
2
# 编译flink on yarn版本
./build.sh csd_on_yarn