qnib/flink

docker-flink 镜像文档

镜像概述

docker-flink是一个包含Flink引擎的Docker镜像，基于Hadoop2环境构建。该镜像旨在提供便捷的Flink分布式计算环境部署方式，简化大数据处理场景下的环境配置流程。Flink作为开源流处理和批处理框架，支持高吞吐、低延迟的数据处理任务。

核心功能和特性

• 集成完整Flink引擎，支持流处理和批处理两种计算模式
• 基于Hadoop2环境构建，兼容Hadoop生态系统组件
• 容器化部署，简化环境依赖管理和版本控制
• 提供独立运行能力，可快速启动Flink集群或单节点实例

使用场景和适用范围

• 大数据流处理应用的开发、测试与部署
• 批处理任务的容器化执行环境
• 快速搭建临时Flink计算环境
• 与Hadoop2集群集成的数据分析任务
• 教学或演示环境中的Flink功能展示

使用方法和配置说明

基本运行命令

启动一个基础Flink容器实例：

bash
docker run -d --name flink-instance docker-flink

端口映射

如需访问Flink Web UI或与其他服务通信，可映射必要端口：

bash
docker run -d --name flink-instance -p 8081:8081 docker-flink

8081为Flink Web UI默认端口

持久化数据

通过挂载卷实现数据持久化：

bash
docker run -d --name flink-instance \
  -v /host/data:/opt/flink/data \
  -v /host/logs:/opt/flink/logs \
  docker-flink

自定义配置

如需使用自定义Flink配置，可挂载配置文件目录：

bash
docker run -d --name flink-instance \
  -v /host/flink-conf:/opt/flink/conf \
  docker-flink

集群模式部署

可通过Docker Compose快速部署Flink集群（示例docker-compose.yml）：

yaml
version: "3"
services:
  jobmanager:
    image: docker-flink
    command: jobmanager
    ports:
      - "8081:8081"
    environment:
      - JOB_MANAGER_RPC_ADDRESS=jobmanager

  taskmanager:
    image: docker-flink
    command: taskmanager
    depends_on:
      - jobmanager
    environment:
      - JOB_MANAGER_RPC_ADDRESS=jobmanager