Apache Flink CDC 3.1.0 Release Announcement The Apache Flink community is excited to announce the release of Flink CDC 3.1.0! This is the first release after the community accepted the donation of Flink CDC as a sub-project of Apache Flink, with exciting new features such as transform and table merging. The eco-system of Flink CDC keeps expanding, including new Kafka and Paimon pipeline sinks and enhancement to existing connectors. We’d like to invite you to check out Flink CDC documentation and have a try on the quickstart tutorial to...

Apache Flink CDC 3.1.1 Release Announcement The Apache Flink Community is pleased to announce the first bug fix release of the Flink CDC 3.1 series. The release contains fixes for several critical issues and improves compatibilities with Apache Flink. 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 to upgrade to Flink CDC 3.

Apache Flink Kubernetes Operator 1.9.0 Release Announcement The Apache Flink community is excited to announce the release of Flink Kubernetes Operator 1.9.0! The release includes many improvements to the autoscaler and standalone autoscaler, as well as memory optimizations to the operator. There was also a lot of progress made to translate documentation to Chinese. 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!

Announcing the Release of Apache Flink 1.20 The Apache Flink PMC is pleased to announce the release of Apache Flink 1.20.0. As usual, we are looking at a packed release with a wide variety of improvements and new features. Overall, 142 people contributed to this release completing 13 FLIPs and 300+ issues. Thank you! Let’s dive into the highlights. Standing on the Eve of Apache Flink 2.0 # Flink 1.0 was released eight years ago. Since several months, the community is actively planning and taking steps towards the next major release.

Apache Flink CDC 3.2.0 Release Announcement The Apache Flink Community is excited to announce the release of Flink CDC 3.2.0! This release aims to improve usability and stability of existing features, including transform and schema evolution. Also, backwards-compatible code and tests have been added to help users upgrade from previous CDC versions more smoothly. 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...

Preview Release of Apache Flink 2.0 The Apache Flink community is actively preparing Flink 2.0, the first major release since Flink 1.0 launched 8 years ago. As a significant milestone, Flink 2.0 is set to introduce numerous innovative features and improvements, along with some compatibility-breaking changes. To facilitate early adaptation to these changes for our users and partner projects (e.g., connectors), and to offer a sneak peek into the exciting new features while gathering feedback, we are now providing a preview...

Apache Flink Kubernetes Operator 1.10.0 Release Announcement The Apache Flink community is excited to announce the release of Flink Kubernetes Operator 1.10.0! The release includes several improvements to the autoscaler, and introduces a new Kubernetes custom resource called FlinkStateSnapshot to manage job snapshots. The process of job upgrades has also been enhanced which makes it possible to now use the last-state upgrade mode with session jobs. We encourage you to download the release and share your experience with the community through the Flink...

Introducing the new Amazon Kinesis Data Stream and Amazon DynamoDB Stream sources We are pleased to introduce updated versions of the Amazon Kinesis Data Stream and Amazon DynamoDB Stream sources. Built on the FLIP-27 source interface, these newer connectors introduce 7 new features and are compatible with Flink 2.0. The new KinesisStreamsSource replaces the legacy FlinkKinesisConsumer; and the new DynamoDbStreamsSource replaces the legacy FlinkDynamoDBStreamsConsumer. The new connectors are available for Flink 1.19 onwards, and AWS Connector version 5.0.0 onwards. For...

Apache Flink CDC 3.2.1 Release Announcement The Apache Flink Community is pleased to announce the first bug fix release of the Flink CDC 3.2 series. The release contains fixes for several critical issues and improves compatibilities with Apache Flink. 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 to upgrade to Flink CDC 3.

Introducing the new Prometheus connector We are excited to announce a new sink connector that enables writing data to Prometheus (FLIP-312). This articles introduces the main features of the connector, and the reasoning behind design decisions. This connector allows writing data to Prometheus using the Remote-Write push interface, which lets you write time-series data to Prometheus at scale. Motivations for a Prometheus connector # Prometheus is an efficient time-series database optimized for building real-time dashboards and...

Apache Flink CDC 3.3.0 Release Announcement The Apache Flink Community is excited to announce the release of Flink CDC 3.3.0! This release introduces more features in transform and connectors and improve usability and stability of existing features. 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! Highlights # Connectors # New Pipeline Connectors # Flink CDC 3.

Apache Flink 1.20.1 Release Announcement The Apache Flink Community is pleased to announce the first bug fix release of the Flink 1.20 series. This release includes 75 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.1.

Apache Flink 1.19.2 Release Announcement The Apache Flink Community is pleased to announce the second bug fix release of the Flink 1.19 series. This release includes 73 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.2.

Apache Flink Kubernetes Operator 1.11.0 Release Announcement The Apache Flink community is excited to announce the release of Flink Kubernetes Operator 1.11.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.0 Preview Support # The Flink Kubernetes Operator and Autoscaler 1.

Apache Flink 2.0.0: A new Era of Real-Time Data Processing Today, the Flink PMC is proud to announce the official release of Apache Flink 2.0.0! This marks the first release in the Flink 2.x series and is the first major release since Flink 1.0 launched nine years ago. This version is the culmination of two years of meticulous preparation and collaboration, signifying a new chapter in the evolution of Flink. In this release, 165 contributors have come together to complete 25 FLIPs (Flink Improvement Proposals) and 369 issues.

Introducing the Externalized Kudu Connector We are pleased to announce the revival of a connector that makes it possible for Flink to interact with Apache Kudu. The original connector existed as part of the Apache Bahir project, which was moved into the attic. Despite this, we saw interest to keep the Kudu connector updated, hence the community agreed to externalize it as a standalone connector in accordance with the current connector development model. For more information about the externalization process, see FLIP-439.

Apache Flink CDC 3.4.0 Release Announcement The Apache Flink Community is excited to announce the release of Flink CDC 3.4.0! This release introduces a new pipeline Connector for Apache Iceberg, and provides support for batch execution mode, 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...

Apache Flink Kubernetes Operator 1.12.0 Release Announcement The Apache Flink community is excited to announce the release of Flink Kubernetes Operator 1.12.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 # Enhanced Error Visibility and Event Reporting # This release places a strong emphasis on improving the visibility and...

Apache Flink 1.20.2 Release Announcement 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.

Apache Flink 1.19.3 Release Announcement 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.

Apache Flink 2.1.0: Ushers in a New Era of Unified Real-Time Data + AI with Comprehensive Upgrades 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:

Apache Flink CDC 3.5.0 Release Announcement 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...

Apache Flink Kubernetes Operator 1.13.0 Release Announcement 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.

Apache Flink 1.20.3 Release Announcement 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.

Apache Flink Agents 0.1.0 Release Announcement 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...

Apache Flink 2.1.1 Release Announcement 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.

Apache Flink 2.0.1 Release Announcement 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.

From Stream to Lakehouse: Kafka Ingestion with the Flink Dynamic Iceberg Sink 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...

Apache Flink 2.2.0: Advancing Real-Time Data + AI and Empowering Stream Processing for the AI Era The Apache Flink PMC is proud to announce the release of Apache Flink 2.2.0. Flink 2.2.0 further enriches AI capabilities, enhances materialized tables and the Connector framework, and improves batch processing and PyFlink support. This release brings together 73 global contributors, implements 9 FLIPs (Flink Improvement Proposals), and resolves over 220 issues. Apache Flink 2.2 ushers in the AI era by seamlessly integrating real-time data processing with artificial intelligence. It...

Apache Flink Agents 0.1.1 Release Announcement The Apache Flink Community is pleased to announce the first bug fix release of the Flink-Agents 0.1 series. This release includes 11 bug fixes, vulnerability fixes, and minor improvements for Flink-Agents 0.1. 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: ISSUE. We highly recommend all users upgrade to Flink-Agents 0.