76f6b299创建于 2025年9月4日历史提交
文件最后提交记录最后更新时间
1 年前
10 个月前
9 个月前
10 个月前
10 个月前
README.md

Quick reference

Apache Flink | openEuler

Current Apache Flink docker images are built on the openEuler. This repository is free to use and exempted from per-user rate limits.

Apache Flink is a framework and distributed processing engine for stateful computations over unbounded and bounded data streams. Flink has been designed to run in all common cluster environments, perform computations at in-memory speed and at any scale.

Learn more on Apache Flink Website.

Supported tags and respective Dockerfile links

The tag of each flink docker image is consist of the version of flink and the version of basic image. The details are as follows

Tags Currently Architectures
2.1.0-oe2403sp1 flink 2.1.0 on openEuler 24.03-LTS-SP1 amd64, arm64
1.16-22.03-lts Apache flink 1.16 on openEuler 22.03-LTS amd64, arm64
2.1.0-oe2403sp2 Apache flink 2.1.0 on openEuler 24.03-LTS-SP2 amd64, arm64

Usage

In this usage, users can select the corresponding {Tag} based on their requirements.

  • Starting a Session Cluster on Docker:

    A Flink Session cluster can be used to run multiple jobs. Each job needs to be submitted to the cluster after the cluster has been deployed. To deploy a Flink Session cluster with Docker, you need to start a JobManager container. To enable communication between the containers, we first set a required Flink configuration property and create a network:

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

    Then we launch the JobManager:

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

    and one or more TaskManager containers:

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

    The web interface is now available at localhost:8081.

    Learn more about how to use Apache Flink with Docker

Question and answering

If you have any questions or want to use some special features, please submit an issue or a pull request on openeuler-docker-images.