Docker 安装

• Flink session cluster
• Flink job cluster
• Flink with Docker Compose

A Flink session cluster can be used to run multiple jobs. Each job needs to be submitted to the cluster after it has been deployed.

The is hosted onDocker Hub and serves images of Flink version 1.2.1 and later.

Images for each supported combination of Hadoop and Scala are available, and tag aliases are provided for convenience.

For example, the following aliases can be used: (1.5.y indicates the latestrelease of Flink 1.5)

• flink:latest →
• flink:1.5 → flink:1.5.y-scala_2.11
• → flink:1.5.y-hadoop27-scala_2.11

Note: The Docker images are provided as a community project by individualson a best-effort basis. They are not official releases by the Apache Flink PMC.

A Flink job cluster is a dedicated cluster which runs a single job. The job is part of the image and, thus, there is no extra job submission needed.

Docker Compose is a convenient way to run agroup of Docker containers locally.

Example config files for a and a job clusterare available on GitHub.

• Launch a cluster in the foreground

• Launch a cluster in the background

• Kill the cluster

When the cluster is running, you can visit the web UI at . You can also use the web UI to submit a job to a session cluster.

For example: