• 1.7.2-hadoop24-scala_2.11
• 1.7.2-hadoop24-scala_2.12, 1.7.2-hadoop24, 1.7-hadoop24
• 1.7.2-hadoop26-scala_2.11
• 1.7.2-hadoop26-scala_2.12, 1.7.2-hadoop26, 1.7-hadoop26
• 1.7.2-hadoop27-scala_2.11
• 1.7.2-hadoop27-scala_2.12, 1.7.2-hadoop27, 1.7-hadoop27
• 1.7.2-hadoop28-scala_2.11
• 1.7.2-hadoop28-scala_2.12, 1.7.2-hadoop28, 1.7-hadoop28
• 1.7.2-scala_2.11, 1.7-scala_2.11
• 1.7.2-scala_2.12, 1.7-scala_2.12, 1.7.2, 1.7
• 1.8.0-scala_2.11, 1.8-scala_2.11, scala_2.11
• 1.8.0-scala_2.12, 1.8-scala_2.12, scala_2.12, 1.8.0, 1.8, latest

• Where to get help:
  Community & Project Info

• Where to file issues:
  https://github.com/docker-flink/docker-flink/issues

• Maintained by:
  members of the Apache Flink community

• Supported architectures: (more info)
  amd64

• Published image artifact details:
  repo-info repo's repos/flink/ directory (history)
  (image metadata, transfer size, etc)

• Image updates:
  official-images PRs with label library/flink
  official-images repo's library/flink file (history)

• Source of this description:
  docs repo's flink/ directory (history)

• Supported Docker versions:
  the latest release (down to 1.6 on a best-effort basis)

Apache Flink is an open source stream processing framework with powerful stream- and batch-processing capabilities.

Learn more about Flink at https://flink.apache.org/

wikipedia.org/wiki/Apache_Flink

Starting with Flink 1.5, images without "hadoop" in the tag are the "Hadoop-free" variant of Flink. If you require Hadoop support (such as its HDFS filesystem implementation), you should reference an image whose tag includes the Hadoop version you need.

You can run a JobManager (master).

$ docker run --name flink_jobmanager -d -t flink jobmanager

You can also run a TaskManager (worker). Notice that workers need to register with the JobManager directly or via ZooKeeper so the master starts to send them tasks to execute.

$ docker run --name flink_taskmanager -d -t flink taskmanager

With Docker Compose you can create a Flink cluster:

version: "2.1"
services:
  jobmanager:
    image: ${FLINK_DOCKER_IMAGE_NAME:-flink}
    expose:
      - "6123"
    ports:
      - "8081:8081"
    command: jobmanager
    environment:
      - JOB_MANAGER_RPC_ADDRESS=jobmanager

  taskmanager:
    image: ${FLINK_DOCKER_IMAGE_NAME:-flink}
    expose:
      - "6121"
      - "6122"
    depends_on:
      - jobmanager
    command: taskmanager
    links:
      - "jobmanager:jobmanager"
    environment:
      - JOB_MANAGER_RPC_ADDRESS=jobmanager

and just run docker-compose up.

Scale the cluster up or down to N TaskManagers:

docker-compose scale taskmanager=<N>

These are the default ports used by the Flink image:

• The Web Client is on port 8081
• JobManager RPC port 6123
• TaskManagers RPC port 6122
• TaskManagers Data port 6121

This repository is available on github.com/docker-flink/docker-flink, and the official build is on the Docker Hub.

This repository is maintained by members of the Apache Flink community.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

      https://www.apache.org/licenses/LICENSE-2.0

Apache Flink, Flink®, Apache®, the squirrel logo, and the Apache feather logo are either registered trademarks or trademarks of The Apache Software Foundation.

As with all Docker images, these likely also contain other software which may be under other licenses (such as Bash, etc from the base distribution, along with any direct or indirect dependencies of the primary software being contained).

Some additional license information which was able to be auto-detected might be found in the repo-info repository's flink/ directory.

As for any pre-built image usage, it is the image user's responsibility to ensure that any use of this image complies with any relevant licenses for all software contained within.