This is an automated email from the ASF dual-hosted git repository.
zakelly pushed a commit to branch asf-site
in repository https://gitbox.apache.org/repos/asf/flink-web.git
The following commit(s) were added to refs/heads/asf-site by this push:
new ec5beb183 Add Flink 2.0.1 release (#813)
ec5beb183 is described below
commit ec5beb183c490975019dd035b8135c6e9c6d24ae
Author: Zakelly <[email protected]>
AuthorDate: Mon Nov 10 16:00:14 2025 +0800
Add Flink 2.0.1 release (#813)
---
docs/content/posts/2025-11-10-release-2.0.1.md | 169 +++++++++++++++++++++++++
docs/data/flink.yml | 14 +-
docs/data/release_archive.yml | 4 +
3 files changed, 180 insertions(+), 7 deletions(-)
diff --git a/docs/content/posts/2025-11-10-release-2.0.1.md
b/docs/content/posts/2025-11-10-release-2.0.1.md
new file mode 100644
index 000000000..c38000484
--- /dev/null
+++ b/docs/content/posts/2025-11-10-release-2.0.1.md
@@ -0,0 +1,169 @@
+---
+title: "Apache Flink 2.0.1 Release Announcement"
+date: "2025-11-10T00:01:00.000Z"
+aliases:
+- /news/2025/11/10/release-2.0.1.html
+authors:
+- zakelly:
+ name: "Zakelly Lan"
+
+---
+
+The Apache Flink Community is pleased to announce the first bug fix release of
the Flink 2.0 series.
+
+This release includes 51 bug fixes, vulnerability fixes, and minor
improvements for Flink 2.0.
+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, please see:
+[JIRA](https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12315522&version=12355557).
+
+We highly recommend all users upgrade to Flink 2.0.1 or higher.
+
+# Release Artifacts
+
+## Maven Dependencies
+
+```xml
+<dependency>
+ <groupId>org.apache.flink</groupId>
+ <artifactId>flink-java</artifactId>
+ <version>2.0.1</version>
+</dependency>
+<dependency>
+ <groupId>org.apache.flink</groupId>
+ <artifactId>flink-streaming-java</artifactId>
+ <version>2.0.1</version>
+</dependency>
+<dependency>
+ <groupId>org.apache.flink</groupId>
+ <artifactId>flink-clients</artifactId>
+ <version>2.0.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.0.1)
(official images)
+* [apache/flink](https://hub.docker.com/r/apache/flink/tags?page=1&name=2.0.1)
(ASF repository)
+
+## PyPi
+
+* [apache-flink==2.0.1](https://pypi.org/project/apache-flink/2.0.1/)
+
+# Release Notes
+
+ Release Notes - Flink - Version 2.0.1
+
+<h2> Bug
+</h2>
+<ul>
+<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-30687'>FLINK-30687</a>] -
FILTER not effect in count(*)
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-33926'>FLINK-33926</a>] -
Can't start a job with a jar in the system classpath in native k8s mode
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-35117'>FLINK-35117</a>] -
AsyncScalarFunction has a dependency issue.
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-37284'>FLINK-37284</a>] -
ForwardForConsecutiveHashPartitioner cannot be chained in Adaptive batch.
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-37309'>FLINK-37309</a>] -
Skewed join optimization not working as expected
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-37337'>FLINK-37337</a>] -
Deploy script SQL Client in Embedded Mode to Kubernetes Results in
FileNotFoundException
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-37350'>FLINK-37350</a>] -
Memory leak caused by skewed join optimization strategy
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-37460'>FLINK-37460</a>] -
Using State Processor API and Kafka Sink with Exactly once delivery leads
to org.apache.kafka.common.errors.InvalidPidMappingException
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-37505'>FLINK-37505</a>] -
Pyflink is not able to handle the new YAML based configs
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-37545'>FLINK-37545</a>] -
StackOverflowError when using MetricGroup in custom WatermarkStrategy
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-37556'>FLINK-37556</a>] -
OpenTelemetry reporter does not package all required classes
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-37557'>FLINK-37557</a>] -
ResolvedSchema#getPrimaryKeyIndexes does not filter for physical columns
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-37576'>FLINK-37576</a>] -
Batch job failed when submit JobGraph contains broadcast edge
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-37605'>FLINK-37605</a>] -
SinkWriter may incorrectly infer end of input during rescale
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-37609'>FLINK-37609</a>] -
Bump parquet libs to 1.15.1
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-37628'>FLINK-37628</a>] -
Wrong reference counting in ForSt file cache
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-37670'>FLINK-37670</a>] -
Watermark alignment can deadlock job if there are no more splits to be
assigned
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-37747'>FLINK-37747</a>] -
GlobalCommitterOperator cannot commit after scaling writer/committer
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-37760'>FLINK-37760</a>] -
Bump parquet version to 1.15.2
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-37783'>FLINK-37783</a>] -
TieredStorage doesn't work when Buffer Debloating is enabled
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-37803'>FLINK-37803</a>] -
LocalTime without seconds is incorrectly serialized to SQL as a value
literal
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-37820'>FLINK-37820</a>] -
AsyncScalarFunction UDFs cannot be loaded via CompiledPlan
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-37833'>FLINK-37833</a>] -
Code generated for binary key in BatchExecExchange causes incorrect shuffle
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-37856'>FLINK-37856</a>] -
Sink option hints are not present in compiled plan
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-37867'>FLINK-37867</a>] -
ForSt StateBackend fail to clean up files of the half-uploaded checkpoint
when using path copying
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-37868'>FLINK-37868</a>] -
Respect the `maxTransferBytes` when using path copying in ForSt
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-37870'>FLINK-37870</a>] -
Unaligned checkpoint is disabled for all connections unexpectedly
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-38030'>FLINK-38030</a>] -
Table.explainSql throw exception: xxx cannot be cast to class
org.apache.flink.table.catalog.AbstractCatalog
+</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-38082'>FLINK-38082</a>] -
User's async function timeout call may result in unexpected retries
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-38098'>FLINK-38098</a>] -
When submitting a task with the flink run command, adding the -sae
parameter will cause the task to be killed
+</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-38195'>FLINK-38195</a>] -
Some markdown syntax errors in tableApi page
+</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-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-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-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'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>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-35622'>FLINK-35622</a>] -
Filter out noisy "Coordinator of operator xxxx does not exist"
exceptions in batch mode
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-37810'>FLINK-37810</a>] -
update log4j to 2.24.3 to fix critical vulnerabilities
+</li>
+</ul>
+
+<h2> Improvement
+</h2>
+<ul>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-33977'>FLINK-33977</a>] -
Adaptive scheduler may not minimize the number of TMs during downscaling
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-37568'>FLINK-37568</a>] -
Improve the method flatten of class GlobalConfiguration
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-37623'>FLINK-37623</a>] -
Async state support for `process()` in Datastream API
+</li>
+<li>[<a
href='https://issues.apache.org/jira/browse/FLINK-37333'>FLINK-37333</a>] -
Use ForwardForUnspecifiedPartitioner when adaptive broadcast join takes
effect
+</li>
+</ul>
\ No newline at end of file
diff --git a/docs/data/flink.yml b/docs/data/flink.yml
index 9cb486d3a..18ec7ff7a 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.1.1/flink-2.1.1-src.tgz.sha512";
2.0:
- name: "Apache Flink 2.0.0"
- binary_release_url:
"https://www.apache.org/dyn/closer.lua/flink/flink-2.0.0/flink-2.0.0-bin-scala_2.12.tgz";
- binary_release_asc_url:
"https://downloads.apache.org/flink/flink-2.0.0/flink-2.0.0-bin-scala_2.12.tgz.asc";
- binary_release_sha512_url:
"https://downloads.apache.org/flink/flink-2.0.0/flink-2.0.0-bin-scala_2.12.tgz.sha512";
- source_release_url:
"https://www.apache.org/dyn/closer.lua/flink/flink-2.0.0/flink-2.0.0-src.tgz";
- source_release_asc_url:
"https://downloads.apache.org/flink/flink-2.0.0/flink-2.0.0-src.tgz.asc";
- source_release_sha512_url:
"https://downloads.apache.org/flink/flink-2.0.0/flink-2.0.0-src.tgz.sha512";
+ name: "Apache Flink 2.0.1"
+ binary_release_url:
"https://www.apache.org/dyn/closer.lua/flink/flink-2.0.1/flink-2.0.1-bin-scala_2.12.tgz";
+ binary_release_asc_url:
"https://downloads.apache.org/flink/flink-2.0.1/flink-2.0.1-bin-scala_2.12.tgz.asc";
+ binary_release_sha512_url:
"https://downloads.apache.org/flink/flink-2.0.1/flink-2.0.1-bin-scala_2.12.tgz.sha512";
+ source_release_url:
"https://www.apache.org/dyn/closer.lua/flink/flink-2.0.1/flink-2.0.1-src.tgz";
+ source_release_asc_url:
"https://downloads.apache.org/flink/flink-2.0.1/flink-2.0.1-src.tgz.asc";
+ source_release_sha512_url:
"https://downloads.apache.org/flink/flink-2.0.1/flink-2.0.1-src.tgz.sha512";
1.20:
name: "Apache Flink 1.20.3"
diff --git a/docs/data/release_archive.yml b/docs/data/release_archive.yml
index 077127369..c56247172 100644
--- a/docs/data/release_archive.yml
+++ b/docs/data/release_archive.yml
@@ -1,5 +1,9 @@
release_archive:
flink:
+ -
+ version_short: "2.0"
+ version_long: 2.0.1
+ release_date: 2025-11-10
-
version_short: "2.1"
version_long: 2.1.1
