基于Docker 构建 Flink 镜像以 Local Cluster 模式运行

基本结构

编辑相关脚本

接入点脚本启动脚本Dockerflie 基于 Dockerfile 构建镜像

构建镜像运行容器查看运行状态

flink-1.13.2：flink的服务文件docker-entrypoint.sh：接入点脚本start.sh：启动脚本Dockerflie：镜像编译文件 编辑相关脚本 接入点脚本

docker-entrypoint.sh

#!/bin/bash
set -e

exec "$@"

start.sh

#!/usr/bin/env bash

./flink-1.13.2/bin/start-cluster.sh

while true
do
    echo "======="
    sleep 60s
done

#基于的基础镜像
FROM java:8
USER root

#flink添加到根目录
ADD flink-1.13.2 /flink-1.13.2
ADD docker-entrypoint.sh /docker-entrypoint.sh
ADD start.sh /start.sh

RUN chmod +x /docker-entrypoint.sh
RUN chmod +x /start.sh

#设置code文件夹的工作目录
WORKDIR /

ENTRYPOINT ["/docker-entrypoint.sh"]
CMD ["/start.sh"]

EXPOSE 8081
EXPOSE 6123

[root@xxxxxxx flink]# docker build -t flink:1.13.2  .
Sending build context to Docker daemon  349.6MB
Step 1/12 : FROM java:8
 ---> d23bdf5b1b1b
Step 2/12 : USER root
 ---> Running in c6dffcd2ad5c
Removing intermediate container c6dffcd2ad5c
 ---> bbb591a2968e
Step 3/12 : ADD flink-1.13.2 /flink-1.13.2
 ---> 1869d8f491ac
Step 4/12 : ADD docker-entrypoint.sh /docker-entrypoint.sh
 ---> edde936c6468
Step 5/12 : ADD start.sh /start.sh
 ---> 41c5b36c1523
Step 6/12 : RUN chmod +x /docker-entrypoint.sh
 ---> Running in d03ea49a93f2
Removing intermediate container d03ea49a93f2
 ---> bad3037aeb6a
Step 7/12 : RUN chmod +x /start.sh
 ---> Running in 3c41dbea986c
Removing intermediate container 3c41dbea986c
 ---> db59c4287bb8
Step 8/12 : WORKDIR /
 ---> Running in d8f778d77d5a
Removing intermediate container d8f778d77d5a
 ---> 8bf986737d13
Step 9/12 : ENTRYPOINT ["/docker-entrypoint.sh"]
 ---> Running in 63ce34205923
Removing intermediate container 63ce34205923
 ---> 579e4f87b740
Step 10/12 : CMD ["/start.sh"]
 ---> Running in 1306f0a4fda1
Removing intermediate container 1306f0a4fda1
 ---> de00aa0126aa
Step 11/12 : EXPOSE 8081
 ---> Running in 7b1de33a90fc
Removing intermediate container 7b1de33a90fc
 ---> b30e6e95f83b
Step 12/12 : EXPOSE 6123
 ---> Running in b75fa55ead17
Removing intermediate container b75fa55ead17
 ---> 5f86c496da25
Successfully built 5f86c496da25
Successfully tagged flink:1.13.2

[root@xxxxxxx flink]# docker run -itd --name=flink -p 8081:8081 flink:1.13.2
f29dcf7e830a74cb8ba087eb44808fa7fa78f1f85da47859db12ca023088b715

[root@xxxxxxx flink]# docker logs flink
Starting cluster.
Starting standalonesession daemon on host f29dcf7e830a.
Starting taskexecutor daemon on host f29dcf7e830a.
=======

访问web验证：http://localhost:8081/