openeuler/flink Docker Image

Apache Flink | openEuler Docker镜像文档

镜像概述和主要用途

本镜像为官方Apache Flink Docker镜像，基于https://repo.openeuler.org/构建，由https://gitee.com/openeuler/cloudnative维护。该镜像可免费使用且无用户速率限制，适用于部署Apache Flink分布式处理引擎，用于有状态计算场景。

Apache Flink是一个框架和分布式处理引擎，专注于无界和有界数据流的有状态计算。其设计目标是在所有常见集群环境中运行，以内存级速度执行计算，并支持任意规模扩展。更多信息可访问https://flink.apache.org/。

核心功能和特性

• 分布式计算能力：支持无界流（实时数据）和有界流（批处理数据）的有状态计算
• 跨环境部署：可在各类集群环境中运行，具备良好的兼容性
• 高性能：以内存级速度处理数据，满足低延迟计算需求
• 可扩展性：支持从单机到大规模集群的无缝扩展
• 基于openEuler：依托openEuler操作系统，提供稳定可靠的运行环境

支持的标签及对应Dockerfile链接

Flink Docker镜像的标签由Flink版本和基础镜像版本组成，具体如下：

使用方法和配置说明

前提条件

用户需根据需求选择对应的{Tag}标签。

在Docker上启动Session Cluster

Flink Session集群可用于运行多个作业，集群部署后需将作业提交至集群。部署步骤如下：

1. 设置配置和创建网络

为实现容器间通信，需先设置必要的Flink配置属性并创建网络：

bash
$ FLINK_PROPERTIES="jobmanager.rpc.address: jobmanager"
$ docker network create flink-network

2. 启动JobManager

bash
$ docker run \
    --rm \
    --name=jobmanager \
    --network flink-network \
    --publish 8081:8081 \
    --env FLINK_PROPERTIES="${FLINK_PROPERTIES}" \
    openeuler/flink:{Tag} jobmanager

3. 启动一个或多个TaskManager

bash
$ docker run \
    --rm \
    --name=taskmanager \
    --network flink-network \
    --env FLINK_PROPERTIES="${FLINK_PROPERTIES}" \
    openeuler/flink:{Tag} taskmanager

4. 访问Web界面

Web界面可通过localhost:8081访问。

更多关于Apache Flink与Docker的使用方法，可参考https://nightlies.apache.org/flink/flink-docs-master/docs/deployment/resource-providers/standalone/docker/。

问题反馈

如有任何问题或需要使用特殊功能，请在https://gitee.com/openeuler/openeuler-docker-images提交issue或pull request。