apache · gaborgsomogyi · Nov 10, 2025 · Oct 2, 2025
diff --git a/docs/config.toml b/docs/config.toml
@@ -43,7 +43,7 @@ posts = "/:year/:month/:day/:title/"
   #  4. Copy the invitation link by clicking on "Copy invite link".
   FlinkSlackInviteUrl = "https://join.slack.com/t/apache-flink/shared_invite/zt-354yyl9vm-LJBlnpbcU~8K_TyIWUhfag"
 
-  FlinkStableVersion = "2.1.0"
+  FlinkStableVersion = "2.1.1"
   FlinkStableShortVersion = "2.1"
   FlinkLTSShortVersion = "1.20"
   StateFunStableVersion = "3.3.0"

diff --git a/docs/content/posts/2025-11-10-release-2.1.1.md b/docs/content/posts/2025-11-10-release-2.1.1.md
@@ -0,0 +1,114 @@
+---
+title:  "Apache Flink 2.1.1 Release Announcement"
+date: "2025-11-10T00:00:00.000Z"
+aliases:
+- /news/2025/11/10/release-2.1.1.html
+authors:
+- gaborgsomogyi:
+  name: "Gabor Somogyi"
+
+---
+
+The Apache Flink Community is pleased to announce the first bug fix release of the Flink 2.1 series.
+
+This release includes 25 bug fixes, vulnerability fixes, and minor improvements for Flink 2.1.
+Below you will find a list of all bugfixes 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=12356162).
+
+We highly recommend all users upgrade to Flink 2.1.1 or higher.
+
+# Release Artifacts
+
+## Maven Dependencies
+
+```xml
+<dependency>
+  <groupId>org.apache.flink</groupId>
+  <artifactId>flink-java</artifactId>
+  <version>2.1.1</version>
+</dependency>
+<dependency>
+  <groupId>org.apache.flink</groupId>
+  <artifactId>flink-streaming-java</artifactId>
+  <version>2.1.1</version>
+</dependency>
+<dependency>
+  <groupId>org.apache.flink</groupId>
+  <artifactId>flink-clients</artifactId>
+  <version>2.1.1</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.1) (official images)
+* [apache/flink](https://hub.docker.com/r/apache/flink/tags?page=1&name=2.1.1) (ASF repository)
+
+## PyPi
+
+* [apache-flink==2.1.1](https://pypi.org/project/apache-flink/2.1.1/)
+
+# Release Notes
+
+
+        Release Notes - Flink - Version 2.1.1
+
+<h2>        Bug
+</h2>
+<ul>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-34094'>FLINK-34094</a>] -         Document new AsyncScalarFunction
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-38149'>FLINK-38149</a>] -         Convert COLUMN_LIST to DescriptorType
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-38219'>FLINK-38219</a>] -         Manipulate state in MultiJoin with fixed row kind
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-38220'>FLINK-38220</a>] -         Adjust JoinToMultiJoinRule to support different types of source
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-16686'>FLINK-16686</a>] -         [State TTL] Make user class loader available in native RocksDB compaction thread
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-38020'>FLINK-38020</a>] -         NonTimeRangeUnboundedPrecedingFunction failing with NPE
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-38035'>FLINK-38035</a>] -         Security Vulnerability in PyFlink Logging Mechanism (PythonEnvUtils.java)
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-38137'>FLINK-38137</a>] -         RocksDB State Backend Null Serialization Causes NPE and Asymmetric (De)Serialization Logic
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-38267'>FLINK-38267</a>] -         Job cannot be recovered from unaligned checkpoint after rescaling when one task has multiple exchanges
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-38272'>FLINK-38272</a>] -         The BatchJobRecoveryTest failed of azure cron adaptive scheduler pipeline
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-38286'>FLINK-38286</a>] -         MAP function with duplicate keys produces non-deterministic results
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-38319'>FLINK-38319</a>] -         TO_TIMESTAMP_LTZ only accepts literal values in PyFlink
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-38327'>FLINK-38327</a>] -         NPE during recovery from file-merged checkpoint after FO
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-38332'>FLINK-38332</a>] -         Upgrade pemja to 0.5.5
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-38336'>FLINK-38336</a>] -         Unexpected data copy during failover for ForSt statebackend
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-38344'>FLINK-38344</a>] -         The local files of the HistoryServer may risk never being deleted.
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-38347'>FLINK-38347</a>] -         Checkpoint file-merging manager may delete the directory unexpectedly when some RPC messages lost
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-38370'>FLINK-38370</a>] -         CommitterOperator does not checkpoint all pending committables
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-38400'>FLINK-38400</a>] -         STDDEV/VAR function with FILTER condition may cause wrong result
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-38415'>FLINK-38415</a>] -         IndexOutOfBoundsException occasionally occurs after rocksdb.use-ingest-db-restore-mode is enabled
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-38433'>FLINK-38433</a>] -         Avoid delete ForSt&#39;s directory when there happened to be an existing one
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-38483'>FLINK-38483</a>] -         Job cannot be recovered from unaligned checkpoint , exception: Cannot get old subtasks from a descriptor that represents no state
+</li>
+</ul>
+
+<h2>        Improvement
+</h2>
+<ul>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-38193'>FLINK-38193</a>] -         Upgrade org.apache.commons:commons-lang3 from 3.12.0 to 3.18.0 to mitigate CVE-2025-48924
+</li>
+</ul>
diff --git a/docs/data/flink.yml b/docs/data/flink.yml
@@ -16,13 +16,13 @@
 # under the License
 
 2.1:
-  name: "Apache Flink 2.1.0"
-  binary_release_url: "https://www.apache.org/dyn/closer.lua/flink/flink-2.1.0/flink-2.1.0-bin-scala_2.12.tgz"
-  binary_release_asc_url: "https://downloads.apache.org/flink/flink-2.1.0/flink-2.1.0-bin-scala_2.12.tgz.asc"
-  binary_release_sha512_url: "https://downloads.apache.org/flink/flink-2.1.0/flink-2.1.0-bin-scala_2.12.tgz.sha512"
-  source_release_url: "https://www.apache.org/dyn/closer.lua/flink/flink-2.1.0/flink-2.1.0-src.tgz"
-  source_release_asc_url: "https://downloads.apache.org/flink/flink-2.1.0/flink-2.1.0-src.tgz.asc"
-  source_release_sha512_url: "https://downloads.apache.org/flink/flink-2.1.0/flink-2.1.0-src.tgz.sha512"
+  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"
 
 2.0:
   name: "Apache Flink 2.0.0"

diff --git a/docs/data/release_archive.yml b/docs/data/release_archive.yml
@@ -1,5 +1,9 @@
 release_archive:
   flink:
+    -
+      version_short: "2.1"
+      version_long: 2.1.1
+      release_date: 2025-11-10
     -
       version_short: "2.1"
       version_long: 2.1.0