apache · ferenc-csaky · May 30, 2025
diff --git a/docs/content/posts/2025-05-30-release-1.20.2.md b/docs/content/posts/2025-05-30-release-1.20.2.md
@@ -0,0 +1,127 @@
+---
+title:  "Apache Flink 1.20.2 Release Announcement"
+date: "2025-05-30T00:00:00.000Z"
+aliases:
+- /news/2025/05/30/release-1.20.2.html
+authors:
+- fcsaky:
+  name: "Ferenc Csaky"
+
+---
+
+The Apache Flink Community is pleased to announce the second bug fix release of the Flink 1.20 series.
+
+This release includes 22 bug fixes, vulnerability fixes, and minor improvements for Flink 1.20.
+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=12355442).
+
+We highly recommend all users upgrade to Flink 1.20.2.
+
+<div class="alert alert-warning" role="alert">
+<b>Note:</b> This release contains an improvement regarding how the Adaptive Scheduler works by default on Kubernetes deployments.
+
+Beforehand, in case of a downscaling, the Adaptive Scheduler was not striving to minimize the active TaskManager number, and free up resources even if it would have been possible.
+This logic is now changed and by default the Adaptive Scheduler will try to maximize TaskManager utilization during a downscale event to be able to minimize the necessary TaskManager number. 
+
+Although this behavioral change pushes the boundaries of a patch release, the community agreed that the applied default is expected in the vast majority of use-cases.
+To keep the previous strategy, make sure you set the `jobmanager.adaptive-scheduler.prefer-minimal-taskmanagers` configuration option to `false`.
+For more details, please see <a href='https://issues.apache.org/jira/browse/FLINK-33977'>FLINK-33977</a>.
+</div>
+
+# Release Artifacts
+
+## Maven Dependencies
+
+```xml
+<dependency>
+  <groupId>org.apache.flink</groupId>
+  <artifactId>flink-java</artifactId>
+  <version>1.20.2</version>
+</dependency>
+<dependency>
+  <groupId>org.apache.flink</groupId>
+  <artifactId>flink-streaming-java</artifactId>
+  <version>1.20.2</version>
+</dependency>
+<dependency>
+  <groupId>org.apache.flink</groupId>
+  <artifactId>flink-clients</artifactId>
+  <version>1.20.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=1.20.2) (official images)
+* [apache/flink](https://hub.docker.com/r/apache/flink/tags?page=1&name=1.20.2) (ASF repository)
+
+## PyPi
+
+* [apache-flink==1.20.2](https://pypi.org/project/apache-flink/1.20.2/)
+
+# Release Notes
+
+        Release Notes - Flink - Version 1.20.2
+
+<h2>        Bug
+</h2>
+<ul>
+<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-34227'>FLINK-34227</a>] -         Job doesn&#39;t disconnect from ResourceManager
+</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-35687'>FLINK-35687</a>] -         JSON_QUERY should return a well formatted nested objects/arrays for ARRAY&lt;STRING&gt;
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-36549'>FLINK-36549</a>] -         Using the ignore-parse-errors parameter in Debezium/Canal/Maxwell/Ogg JSON results in unexpected data loss.
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-37205'>FLINK-37205</a>] -         Correct the state cache behavior during bump beam version
+</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-37480'>FLINK-37480</a>] -         Jpicmp gives false positive
+</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-37557'>FLINK-37557</a>] -         ResolvedSchema#getPrimaryKeyIndexes does not filter for physical columns
+</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-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-37760'>FLINK-37760</a>] -         Bump parquet version to 1.15.2
+</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>
+</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-37109'>FLINK-37109</a>] -         Improve state processor API performance when reading keyed rocksdb state by allowing duplicates
+</li>
+</ul>
+
+<h2>        Technical Debt
+</h2>
+<ul>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-37241'>FLINK-37241</a>] -         Remove Mockito dependency from StateBackendTestBase
+</li>
+<li>[<a href='https://issues.apache.org/jira/browse/FLINK-37360'>FLINK-37360</a>] -         Update japicmp configuration post 1.20.1
+</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>
diff --git 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.0.0/flink-2.0.0-src.tgz.sha512"
 
 1.20:
-  name: "Apache Flink 1.20.1"
-  binary_release_url: "https://www.apache.org/dyn/closer.lua/flink/flink-1.20.1/flink-1.20.1-bin-scala_2.12.tgz"
-  binary_release_asc_url: "https://downloads.apache.org/flink/flink-1.20.1/flink-1.20.1-bin-scala_2.12.tgz.asc"
-  binary_release_sha512_url: "https://downloads.apache.org/flink/flink-1.20.1/flink-1.20.1-bin-scala_2.12.tgz.sha512"
-  source_release_url: "https://www.apache.org/dyn/closer.lua/flink/flink-1.20.1/flink-1.20.1-src.tgz"
-  source_release_asc_url: "https://downloads.apache.org/flink/flink-1.20.1/flink-1.20.1-src.tgz.asc"
-  source_release_sha512_url: "https://downloads.apache.org/flink/flink-1.20.1/flink-1.20.1-src.tgz.sha512"
+  name: "Apache Flink 1.20.2"
+  binary_release_url: "https://www.apache.org/dyn/closer.lua/flink/flink-1.20.2/flink-1.20.2-bin-scala_2.12.tgz"
+  binary_release_asc_url: "https://downloads.apache.org/flink/flink-1.20.2/flink-1.20.2-bin-scala_2.12.tgz.asc"
+  binary_release_sha512_url: "https://downloads.apache.org/flink/flink-1.20.2/flink-1.20.2-bin-scala_2.12.tgz.sha512"
+  source_release_url: "https://www.apache.org/dyn/closer.lua/flink/flink-1.20.2/flink-1.20.2-src.tgz"
+  source_release_asc_url: "https://downloads.apache.org/flink/flink-1.20.2/flink-1.20.2-src.tgz.asc"
+  source_release_sha512_url: "https://downloads.apache.org/flink/flink-1.20.2/flink-1.20.2-src.tgz.sha512"
   release_notes_url: "https://nightlies.apache.org/flink/flink-docs-release-1.20/release-notes/flink-1.20"
 
 1.19:

diff --git a/docs/data/release_archive.yml b/docs/data/release_archive.yml
@@ -4,6 +4,10 @@ release_archive:
       version_short: "2.0"
       version_long: 2.0.0
       release_date: 2025-03-24
+    -
+      version_short: "1.20"
+      version_long: 1.20.2
+      release_date: <TBA>
     -
       version_short: "1.20"
       version_long: 1.20.1