From Stream to Lakehouse: Kafka Ingestion with the Flink Dynamic Iceberg Sink

November 11, 2025 - Swapna Marru

Ingesting thousands of evolving Kafka topics into a lakehouse often creates complex, brittle pipelines that require constant manual intervention as its write patterns change. But what if your ingestion pipeline could adapt on its own, with zero downtime? Enter the Flink Dynamic Iceberg Sink, a powerful pattern for Apache Flink that allows users to write streaming data into multiple Iceberg tables—dynamically, efficiently, and with full schema evolution support. The sink can create and write to new tables based on instructions within the records themselves. ...

Continue reading »

Apache Flink 2.0.1 Release Announcement

November 10, 2025 - 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. We highly recommend all users upgrade to Flink 2. ...

Continue reading »

Apache Flink 2.1.1 Release Announcement

November 10, 2025 - Gabor Somogyi

The Apache Flink Community is pleased to announce the first bug fix release of the Flink 2.1 series. This release includes 25 bug fixes, vulnerability fixes, and minor improvements for Flink 2.1. 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 2.1.1 or higher. ...

Continue reading »

Apache Flink Agents 0.1.0 Release Announcement

October 15, 2025 - Xintong Song

The Apache Flink Community is excited to announce the first preview release of Apache Flink Agents (0.1.0). What is Apache Flink Agents # Apache Flink Agents is a new sub-project of Apache Flink for building event-driven AI agents directly on Flink’s streaming runtime. It unifies stream processing and autonomous agents in one framework, combining Flink’s proven strengths – scale, low latency, fault tolerance, and state management – with agent capabilities – LLMs, tools, memory, and dynamic orchestration. ...

Continue reading »

Apache Flink 1.20.3 Release Announcement

October 9, 2025 - Xuannan Su

The Apache Flink Community is pleased to announce the second bug fix release of the Flink 1.20 series. This release includes 16 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. We highly recommend all users upgrade to Flink 1.20.3 or higher. ...

Continue reading »

Apache Flink Kubernetes Operator 1.13.0 Release Announcement

September 29, 2025 - Ferenc Csaky

The Apache Flink community is excited to announce the release of Flink Kubernetes Operator 1.13.0! The version brings a number of important fixes and improvements to both core and autoscaler modules. We encourage you to download the release and share your experience with the community through the Flink mailing lists or JIRA! We’re looking forward to your feedback! Highlights # Flink 2.1 Support # The Flink Kubernetes Operator and Autoscaler 1. ...

Continue reading »

Apache Flink CDC 3.5.0 Release Announcement

September 26, 2025 - Yanquan Lv

The Apache Flink Community is excited to announce the release of Flink CDC 3.5.0! This release introduces new pipeline connectors for Apache Fluss and PostgreSQL, and improves usability in multi-tables (with frequent table structure changes) synchronization scenario, many issues encountered in the transform and Schema evolution frameworks have also been fixed. Flink CDC release packages are available at Releases Page, and documentations are available at Flink CDC documentation page. Looking forward to any feedback from the community through the Flink mailing lists or JIRA! ...

Continue reading »

Apache Flink 2.1.0: Ushers in a New Era of Unified Real-Time Data + AI with Comprehensive Upgrades

July 31, 2025 - Ron Liu (@Ron999)

The Apache Flink PMC is proud to announce the release of Apache Flink 2.1.0. This marks a significant milestone in the evolution of the real-time data processing engine into a unified Data + AI platform. This release brings together 116 global contributors, implements 16 FLIPs (Flink Improvement Proposals), and resolves over 220 issues, with a strong focus on deepening the integration of real-time AI and intelligent stream processing: Breakthroughs in Real-Time AI: ...

Continue reading »

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. ...

Continue reading »

Apache Flink 1.20.2 Release Announcement

July 10, 2025 - 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. We highly recommend all users upgrade to Flink 1.20.2 or higher. ...

Continue reading »