ueqt/flink

Flink Docker镜像

镜像概述和主要用途

本镜像提供Apache Flink分布式流处理引擎的容器化部署方案，包含official和latest两个标签。official版本基于官方Flink优化，解决了官方镜像在Rancher环境中日志不可见、openjdk导致的进程kill错误及任务运行失败等问题；latest版本为自实现版本，集成Python3环境，支持Rancher部署，提供灵活的配置选项，适用于需要Python支持的Flink应用场景。

核心功能和特性

official标签

• 日志可见性优化：修复官方Flink镜像在Rancher中无法查看日志的问题（解决stdout文件不可访问问题）
• 运行稳定性提升：替换官方镜像中的openjdk基础环境，解决任务运行时的kill错误和任务执行失败问题
• 兼容性保障：使用方式与官方Flink镜像完全一致，可直接参考官方文档进行操作

latest标签

• Python3环境集成：内置Python3运行环境，支持Flink Python API及Python UDF
• Rancher支持：针对Rancher容器管理平台优化，确保集群部署兼容性
• 灵活配置：通过环境变量自定义集群参数，适应不同规模的部署需求

使用场景和适用范围

• 在Rancher平台部署Flink集群，需要解决日志监控问题的场景
• 官方Flink镜像运行不稳定，需要修复进程kill错误和任务执行问题的场景
• 开发或运行依赖Python环境的Flink应用（如PyFlink作业）
• 需要快速部署Flink集群，且希望简化配置流程的场景

使用方法和配置说明

镜像拉取

official版本

bash
docker pull ueqt/flink:official

latest版本

bash
docker pull ueqt/flink

构建镜像（仅official版本）

bash
docker build . -t ueqt/flink

运行容器

official版本（与官方用法一致）

启动JobManager：

bash
docker run -it ueqt/flink:official jobmanager

启动TaskManager：

bash
docker run -it ueqt/flink:official taskmanager

详细使用方法参考https://hub.docker.com/_/flink

latest版本

环境变量配置（均为可选）：

• JOB_MANAGER_RPC_ADDRESS：JobManager的RPC地址，可设为IP或K8s服务别名，默认使用hostname
• MANAGER_TYPE：节点类型，可选值为job（主节点）或task（工作节点），默认值为job
• TASK_MANAGER_NUMBER_OF_TASK_SLOTS：TaskManager的任务槽数量，默认值为CPU核心数（仅TaskManager生效）

端口映射：

• JobManager（主机）：需映射8081（Web UI）、6123、6124、6125端口
• TaskManager（子机）：需映射6121、6122、6124、6125端口

启动示例： 启动JobManager：

bash
docker run -it -p 8081:8081 -p 6123:6123 -p 6124:6124 -p 6125:6125 ueqt/flink

启动TaskManager（连接到指定JobManager）：

bash
docker run -it -e JOB_MANAGER_RPC_ADDRESS=jobmanager-host -e MANAGER_TYPE=task -p 6121:6121 -p 6122:6122 -p 6124:6124 -p 6125:6125 ueqt/flink