Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
142 changes: 142 additions & 0 deletions docs/content/posts/2026-04-22-release-2.1.2.md
Original file line number Diff line number Diff line change
@@ -0,0 +1,142 @@
---
title: "Apache Flink 2.1.2 Release Announcement"
date: "2026-04-22T00:00:00.000Z"
aliases:
- /news/2026/04/22/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&#39;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&#39;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 &#39;pkg_resources&#39;
</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&#39;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&#39;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>
14 changes: 7 additions & 7 deletions docs/data/flink.yml
Original file line number Diff line number Diff line change
Expand Up @@ -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.1"
Expand Down
3 changes: 3 additions & 0 deletions docs/data/release_archive.yml
Original file line number Diff line number Diff line change
@@ -1,5 +1,8 @@
release_archive:
flink:
- version_short: "2.1"
version_long: 2.1.2
release_date: 2026-04-22
-
version_short: "2.2"
version_long: 2.2.0
Expand Down