diff --git a/website/www/site/content/en/documentation/runners/flink.md b/website/www/site/content/en/documentation/runners/flink.md index 2fc4bc83bb70..1549857068fa 100644 --- a/website/www/site/content/en/documentation/runners/flink.md +++ b/website/www/site/content/en/documentation/runners/flink.md @@ -93,7 +93,7 @@ from the [compatibility table](#flink-version-compatibility) below. For example: {{< highlight java >}} org.apache.beam - beam-runners-flink-1.14 + beam-runners-flink-1.16 {{< param release_latest >}} {{< /highlight >}} @@ -201,6 +201,8 @@ Starting with Beam 2.18.0, pre-built Flink Job Service Docker images are availab [Flink 1.12](https://hub.docker.com/r/apache/beam_flink1.12_job_server). [Flink 1.13](https://hub.docker.com/r/apache/beam_flink1.13_job_server). [Flink 1.14](https://hub.docker.com/r/apache/beam_flink1.14_job_server). +[Flink 1.15](https://hub.docker.com/r/apache/beam_flink1.15_job_server). +[Flink 1.16](https://hub.docker.com/r/apache/beam_flink1.16_job_server). {{< /paragraph >}} @@ -313,8 +315,8 @@ reference. ## Flink Version Compatibility The Flink cluster version has to match the minor version used by the FlinkRunner. -The minor version is the first two numbers in the version string, e.g. in `1.13.0` the -minor version is `1.13`. +The minor version is the first two numbers in the version string, e.g. in `1.16.0` the +minor version is `1.16`. We try to track the latest version of Apache Flink at the time of the Beam release. A Flink version is supported by Beam for the time it is supported by the Flink community. @@ -328,42 +330,93 @@ To find out which version of Flink is compatible with Beam please see the table Artifact Id - ≥ 2.38.0 - 1.14.x * + ≥ 2.47.0 + 1.16.x + beam-runners-flink-1.16 + + + 1.15.x + beam-runners-flink-1.15 + + + 1.14.x + beam-runners-flink-1.14 + + + 1.13.x + beam-runners-flink-1.13 + + + 1.12.x + beam-runners-flink-1.12 + + + 2.40.0 - 2.46.0 + 1.15.x + beam-runners-flink-1.15 + + + 1.14.x + beam-runners-flink-1.14 + + + 1.13.x + beam-runners-flink-1.13 + + + 1.12.x + beam-runners-flink-1.12 + + + 2.39.0 + 1.14.x beam-runners-flink-1.14 - 1.13.x * + 1.13.x beam-runners-flink-1.13 - 1.12.x * + 1.12.x beam-runners-flink-1.12 - 1.11.x * + 2.38.0 + 1.14.x + beam-runners-flink-1.14 + + + 1.13.x + beam-runners-flink-1.13 + + + 1.12.x + beam-runners-flink-1.12 + + + 1.11.x beam-runners-flink-1.11 2.31.0 - 2.37.0 - 1.13.x * + 1.13.x beam-runners-flink-1.13 - 1.12.x * + 1.12.x beam-runners-flink-1.12 - 1.11.x * + 1.11.x beam-runners-flink-1.11 2.30.0 - 1.12.x * + 1.12.x beam-runners-flink-1.12 - 1.11.x * + 1.11.x beam-runners-flink-1.11 @@ -372,11 +425,11 @@ To find out which version of Flink is compatible with Beam please see the table 2.27.0 - 2.29.0 - 1.12.x * + 1.12.x beam-runners-flink-1.12 - 1.11.x * + 1.11.x beam-runners-flink-1.11 @@ -393,7 +446,7 @@ To find out which version of Flink is compatible with Beam please see the table 2.25.0 - 2.26.0 - 1.11.x * + 1.11.x beam-runners-flink-1.11 @@ -504,8 +557,6 @@ To find out which version of Flink is compatible with Beam please see the table -* This version does not have a published docker image for the Flink Job Service. - For retrieving the right Flink version, see the [Flink downloads page](https://flink.apache.org/downloads.html). For more information, the [Flink Documentation](https://ci.apache.org/projects/flink/flink-docs-stable/) can be helpful.