This is an automated email from the ASF dual-hosted git repository. snuyanzin pushed a commit to branch asf-site in repository https://gitbox.apache.org/repos/asf/flink-web.git
commit 27c90b966d42b21ade14caba4677964af59ccd23 Author: Sergey Nuyanzin <[email protected]> AuthorDate: Fri Apr 17 00:34:57 2026 +0200 Add Flink 2.1.2 release --- docs/content/posts/2026-05-11-release-2.1.2.md | 142 +++++++++++++++++++++++++ docs/data/flink.yml | 14 +-- docs/data/release_archive.yml | 6 +- 3 files changed, 154 insertions(+), 8 deletions(-) diff --git a/docs/content/posts/2026-05-11-release-2.1.2.md b/docs/content/posts/2026-05-11-release-2.1.2.md new file mode 100644 index 0000000000..6be5afabfc --- /dev/null +++ b/docs/content/posts/2026-05-11-release-2.1.2.md @@ -0,0 +1,142 @@ +--- +title: "Apache Flink 2.1.2 Release Announcement" +date: "2026-05-11T00:00:00.000Z" +aliases: +- /news/2026/05/11/release-2.1.2.html +authors: +- snuyanzin: + name: "Sergey Nuyanzin" + +--- + +The Apache Flink Community is pleased to announce the second bug fix release of the Flink 2.1 series. + +This release includes 45 bug fixes, vulnerability fixes, and minor improvements for Flink 2.1. +Below you will find a list of all bug fixes and improvements (excluding improvements to the build infrastructure and build stability). For a complete list of all changes see: +[JIRA](https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12315522&version=12356307). + +We highly recommend all users upgrade to Flink 2.1.2 or higher. + +# Release Artifacts + +## Maven Dependencies + +```xml +<dependency> + <groupId>org.apache.flink</groupId> + <artifactId>flink-java</artifactId> + <version>2.1.2</version> +</dependency> +<dependency> + <groupId>org.apache.flink</groupId> + <artifactId>flink-streaming-java</artifactId> + <version>2.1.2</version> +</dependency> +<dependency> + <groupId>org.apache.flink</groupId> + <artifactId>flink-clients</artifactId> + <version>2.1.2</version> +</dependency> +``` + +## Binaries + +You can find the binaries on the updated [Downloads page]({{< relref "downloads" >}}). + +## Docker Images + +* [library/flink](https://hub.docker.com/_/flink/tags?page=1&name=2.1.2) (official images) +* [apache/flink](https://hub.docker.com/r/apache/flink/tags?page=1&name=2.1.2) (ASF repository) + +## PyPi + +* [apache-flink==2.1.2](https://pypi.org/project/apache-flink/2.1.2/) + +# Release Notes + + + Release Notes - Flink - Version 2.1.2 + +<h2> Bug +</h2> +<ul> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-35556'>FLINK-35556</a>] - Wrong constant in RocksDBSharedResourcesFactory.SLOT_SHARED_MANAGED +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-37266'>FLINK-37266</a>] - Python CLI arguments doesn't work in session mode +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-38399'>FLINK-38399</a>] - As long as the join key includes one of the indexes from the source, the join can be converted into a delta join +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-38486'>FLINK-38486</a>] - Harden shutdown of DefaultExpressionEvaluator +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-38567'>FLINK-38567</a>] - ForSt state backend error with GROUP BY and async state execution +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-38574'>FLINK-38574</a>] - Avoid reusing re-uploaded sst files when checkpoint notification is delayed +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-38585'>FLINK-38585</a>] - Pyflink's thread mode may not work when using shipped venv.zip archive as virtual env +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-38586'>FLINK-38586</a>] - ClassCastException when using Delta Join with lookup cache +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-38624'>FLINK-38624</a>] - Flink 2.1 Job Failure: Type Mismatch Exception in StreamPhysicalOverAggregateRule (TIMESTAMP(3) vs TIMESTAMP(3) ROWTIME) +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-38703'>FLINK-38703</a>] - ConcurrentModificationException in FineGrainedResourceManager during reporting metrics +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-38704'>FLINK-38704</a>] - Metrics reporter setup does not load Prometheus with correct configs/port +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-38750'>FLINK-38750</a>] - Validation of queries with functions erroneously invoked under select fails with StackOverflow +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-38797'>FLINK-38797</a>] - PyFlink CsvSchemaBuilder.set_null_value method missing return self +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-38815'>FLINK-38815</a>] - The debug log will print the sensitive information of data security cookie certification in task manager and jobmanager +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-38916'>FLINK-38916</a>] - MultiJoin produces incorrect results for OR join conditions when parallelism is greater than 1 +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-38938'>FLINK-38938</a>] - Restore of SQL job with CURRENT_TIMESTAMP fails with CodeGenException +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-38951'>FLINK-38951</a>] - Upgrade pemja to 0.5.6 +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-38986'>FLINK-38986</a>] - SSL connection failures in BlobClientSslTest / NettyClientServerSslTest with latest JDK versions +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-39015'>FLINK-39015</a>] - Fix MultiJoin RowData behaviour for HeapStateBackend +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-39017'>FLINK-39017</a>] - Flink WebUI Job graph node click interaction fails in Chrome 144+ (PointerEvents suppression) +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-39052'>FLINK-39052</a>] - ModuleNotFoundError: No module named 'pkg_resources' +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-39130'>FLINK-39130</a>] - Allow native types to be used for MetricConfig +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-39242'>FLINK-39242</a>] - Method getDataType does not exist error when getting columns from ResolvedSchema +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-39355'>FLINK-39355</a>] - Table program cannot be compiled for JSON_OBJECT +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-39360'>FLINK-39360</a>] - LIKE clause doesn't support some patterns +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-39371'>FLINK-39371</a>] - CurrentDatabase fails for some patterns +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-39394'>FLINK-39394</a>] - Job overview metrics (business/backpressure/data skew) are showing N/A when some nodes are finished +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-39395'>FLINK-39395</a>] - Add spotless upToDateChecking +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-39424'>FLINK-39424</a>] - Setting LIKE does not support default escape characters. +</li> +</ul> + +<h2> Improvement +</h2> +<ul> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-37881'>FLINK-37881</a>] - Drop gosu in favour of Dockerfile's USER +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-38417'>FLINK-38417</a>] - Ensure attribute ordering when managing join attributes in JoinKeyExtractor +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-38445'>FLINK-38445</a>] - Create test plans to validate upsert keys +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-38914'>FLINK-38914</a>] - Redirect users to deeplink when visiting an outdated or master docs page (instead of stable) +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-38924'>FLINK-38924</a>] - Redirect users to documentation home page when encountering a 404 +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-38925'>FLINK-38925</a>] - Update Matomo URL to the right domain +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-38955'>FLINK-38955</a>] - Add canonical tag to generated Javadoc and PyDocs +</li> +<li>[<a href='https://issues.apache.org/jira/browse/FLINK-39139'>FLINK-39139</a>] - Update lz4-java to 1.10.3 +</li> +</ul> diff --git a/docs/data/flink.yml b/docs/data/flink.yml index 9ce3d279ff..d7ded5304c 100644 --- a/docs/data/flink.yml +++ b/docs/data/flink.yml @@ -25,13 +25,13 @@ source_release_sha512_url: "https://downloads.apache.org/flink/flink-2.2.0/flink-2.2.0-src.tgz.sha512"; 2.1: - name: "Apache Flink 2.1.1" - binary_release_url: "https://www.apache.org/dyn/closer.lua/flink/flink-2.1.1/flink-2.1.1-bin-scala_2.12.tgz"; - binary_release_asc_url: "https://downloads.apache.org/flink/flink-2.1.1/flink-2.1.1-bin-scala_2.12.tgz.asc"; - binary_release_sha512_url: "https://downloads.apache.org/flink/flink-2.1.1/flink-2.1.1-bin-scala_2.12.tgz.sha512"; - source_release_url: "https://www.apache.org/dyn/closer.lua/flink/flink-2.1.1/flink-2.1.1-src.tgz"; - source_release_asc_url: "https://downloads.apache.org/flink/flink-2.1.1/flink-2.1.1-src.tgz.asc"; - source_release_sha512_url: "https://downloads.apache.org/flink/flink-2.1.1/flink-2.1.1-src.tgz.sha512"; + name: "Apache Flink 2.1.2" + binary_release_url: "https://www.apache.org/dyn/closer.lua/flink/flink-2.1.2/flink-2.1.2-bin-scala_2.12.tgz"; + binary_release_asc_url: "https://downloads.apache.org/flink/flink-2.1.2/flink-2.1.2-bin-scala_2.12.tgz.asc"; + binary_release_sha512_url: "https://downloads.apache.org/flink/flink-2.1.2/flink-2.1.2-bin-scala_2.12.tgz.sha512"; + source_release_url: "https://www.apache.org/dyn/closer.lua/flink/flink-2.1.2/flink-2.1.2-src.tgz"; + source_release_asc_url: "https://downloads.apache.org/flink/flink-2.1.2/flink-2.1.2-src.tgz.asc"; + source_release_sha512_url: "https://downloads.apache.org/flink/flink-2.1.2/flink-2.1.2-src.tgz.sha512"; 2.0: name: "Apache Flink 2.0.2" diff --git a/docs/data/release_archive.yml b/docs/data/release_archive.yml index 55e37ecb64..0d4db959ea 100644 --- a/docs/data/release_archive.yml +++ b/docs/data/release_archive.yml @@ -1,9 +1,13 @@ release_archive: flink: + - + version_short: "2.1" + version_long: 2.1.2 + release_date: 2026-05-11 - version_short: "2.0" version_long: 2.0.2 - release_date: 2026-05-08 + release_date: 2026-05-11 - version_short: "1.20" version_long: 1.20.4
