• 1.2.1-hadoop2-scala_2.10 (1.2/hadoop2-scala_2.10-debian/Dockerfile)
• 1.2.1-hadoop2-scala_2.11, 1.2.1-hadoop2, 1.2-hadoop2 (1.2/hadoop2-scala_2.11-debian/Dockerfile)
• 1.2.1-hadoop24-scala_2.10 (1.2/hadoop24-scala_2.10-debian/Dockerfile)
• 1.2.1-hadoop24-scala_2.11, 1.2.1-hadoop24, 1.2-hadoop24 (1.2/hadoop24-scala_2.11-debian/Dockerfile)
• 1.2.1-hadoop26-scala_2.10 (1.2/hadoop26-scala_2.10-debian/Dockerfile)
• 1.2.1-hadoop26-scala_2.11, 1.2.1-hadoop26, 1.2-hadoop26 (1.2/hadoop26-scala_2.11-debian/Dockerfile)
• 1.2.1-hadoop27-scala_2.10, 1.2.1-scala_2.10, 1.2-scala_2.10 (1.2/hadoop27-scala_2.10-debian/Dockerfile)
• 1.2.1-hadoop27-scala_2.11, 1.2.1-scala_2.11, 1.2-scala_2.11, 1.2.1-hadoop27, 1.2-hadoop27, 1.2.1, 1.2 (1.2/hadoop27-scala_2.11-debian/Dockerfile)
• 1.3.1-hadoop2-scala_2.10 (1.3/hadoop2-scala_2.10-debian/Dockerfile)
• 1.3.1-hadoop2-scala_2.11, 1.3.1-hadoop2, 1.3-hadoop2, hadoop2 (1.3/hadoop2-scala_2.11-debian/Dockerfile)
• 1.3.1-hadoop24-scala_2.10 (1.3/hadoop24-scala_2.10-debian/Dockerfile)
• 1.3.1-hadoop24-scala_2.11, 1.3.1-hadoop24, 1.3-hadoop24, hadoop24 (1.3/hadoop24-scala_2.11-debian/Dockerfile)
• 1.3.1-hadoop26-scala_2.10 (1.3/hadoop26-scala_2.10-debian/Dockerfile)
• 1.3.1-hadoop26-scala_2.11, 1.3.1-hadoop26, 1.3-hadoop26, hadoop26 (1.3/hadoop26-scala_2.11-debian/Dockerfile)
• 1.3.1-hadoop27-scala_2.10, 1.3.1-scala_2.10, 1.3-scala_2.10, scala_2.10 (1.3/hadoop27-scala_2.10-debian/Dockerfile)
• 1.3.1-hadoop27-scala_2.11, 1.3.1-scala_2.11, 1.3-scala_2.11, scala_2.11, 1.3.1-hadoop27, 1.3-hadoop27, hadoop27, 1.3.1, 1.3, latest (1.3/hadoop27-scala_2.11-debian/Dockerfile)

• 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

• 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

To run a single Flink local cluster:

$ docker run --name flink_local -p 8081:8081 -t flink local

Then with a web browser go to http://localhost:8081/ to see the Flink Web Dashboard (adjust the hostname for your Docker host).

To use Flink, you can submit a job to the cluster using the Web UI or you can also do it from a different Flink container, for example:

$ docker run --rm -t flink flink run -m <jobmanager:port> -c <your_class> <your_jar> <your_params>

You can run a JobManager (master).

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

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.