Add Flink 1.20.2 release #797
There are no files selected for viewing
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,133 @@ | ||
| --- | ||
| 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 25 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. | ||
|
There was a problem hiding this comment. nit: use-case -> 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'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<STRING> | ||
| </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> | ||
| <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-37870'>FLINK-37870</a>] - Unaligned checkpoint is disabled for all connections unexpectedly | ||
| </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-37804'>FLINK-37804</a>] - Python failed to build wheels on macos | ||
| </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> | ||
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Are we recommending this over version 2? I think we need a sentence positioning with version 2 here instead.