Apache Flink 1.19.3 Release Announcement

July 10, 2025 - Ferenc Csaky

The Apache Flink Community is pleased to announce the third bug fix release of the Flink 1.19 series.

This release includes 14 bug fixes, vulnerability fixes, and minor improvements for Flink 1.19. 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.

We highly recommend all users upgrade to Flink 1.19.3 or higher.

Note: 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 FLINK-33977.

Release Artifacts #

Maven Dependencies #

<dependency>
  <groupId>org.apache.flink</groupId>
  <artifactId>flink-java</artifactId>
  <version>1.19.3</version>
</dependency>
<dependency>
  <groupId>org.apache.flink</groupId>
  <artifactId>flink-streaming-java</artifactId>
  <version>1.19.3</version>
</dependency>
<dependency>
  <groupId>org.apache.flink</groupId>
  <artifactId>flink-clients</artifactId>
  <version>1.19.3</version>
</dependency>

Binaries #

You can find the binaries on the updated Downloads page.

Docker Images #

library/flink (official images)
apache/flink (ASF repository)

PyPi #

apache-flink==1.19.3

Release Notes #

    Release Notes - Flink - Version 1.19.3

Bug

[FLINK-34227] - Job doesn't disconnect from ResourceManager
[FLINK-36549] - Using the ignore-parse-errors parameter in Debezium/Canal/Maxwell/Ogg JSON results in unexpected data loss.
[FLINK-37505] - Pyflink is not able to handle the new YAML based configs
[FLINK-37605] - SinkWriter may incorrectly infer end of input during rescale
[FLINK-37609] - Bump parquet libs to 1.15.1
[FLINK-37760] - Bump parquet version to 1.15.2
[FLINK-37783] - TieredStorage doesn't work when Buffer Debloating is enabled
[FLINK-37803] - LocalTime without seconds is incorrectly serialized to SQL as a value literal
[FLINK-37820] - AsyncScalarFunction UDFs cannot be loaded via CompiledPlan
[FLINK-37833] - Code generated for binary key in BatchExecExchange causes incorrect shuffle
[FLINK-37870] - Unaligned checkpoint is disabled for all connections unexpectedly

Improvement

[FLINK-33977] - Adaptive scheduler may not minimize the number of TMs during downscaling

Technical Debt

[FLINK-37361] - Update japicmp configuration post 1.19.2
[FLINK-37804] - Python failed to build wheels on macos