Apache Flink 1.15.4 Release Announcement

March 15, 2023 - Danny Cranmer

The Apache Flink Community is pleased to announce the fourth bug fix release of the Flink 1.15 series. This release includes 53 bug fixes, vulnerability fixes, and minor improvements for Flink 1.15. 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.15.4. ...

Continue reading »

Apache Flink Kubernetes Operator 1.4.0 Release Announcement

February 27, 2023 - Gyula Fora (@GyulaFora) Maximilian Michels (@stadtlegende) Matyas Orhidi (@matyasorhidi)

We are proud to announce the latest stable release of the operator. In addition to the expected stability improvements and fixes, the 1.4.0 release introduces the first version of the long-awaited autoscaler module. Flink Streaming Job Autoscaler # A highly requested feature for Flink applications is the ability to scale the pipeline based on incoming data load and the utilization of the dataflow. While Flink has already provided some of the required building blocks, this feature has not yet been realized in the open source ecosystem. ...

Continue reading »

Apache Flink 1.16.1 Release Announcement

January 30, 2023 - Martijn Visser (@martijnvisser82)

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

Continue reading »

Delegation Token Framework: Obtain, Distribute and Use Temporary Credentials Automatically

January 20, 2023 - Gabor Somogyi Marton Balassi (@MartonBalassi)

The Apache Flink Community is pleased to announce that the upcoming minor version of Flink (1.17) includes the Delegation Token Framework proposed in FLIP-272. This enables Flink to authenticate to external services at a central location (JobManager) and distribute authentication tokens to the TaskManagers. Introduction # Authentication in distributed systems is not an easy task. Previously all worker nodes (TaskManagers) reading from or writing to an external system needed to authenticate on their own. ...

Continue reading »

Apache Flink Table Store 0.3.0 Release Announcement

January 13, 2023 - Jingsong Lee

The Apache Flink community is pleased to announce the release of the Apache Flink Table Store (0.3.0). We highly recommend all users upgrade to Flink Table Store 0.3.0. 0.3.0 completed 150+ issues, which were completed by nearly 30 contributors. Please check out the full documentation for detailed information and user guides. Flink Table Store 0.3 completes many exciting features, enhances its ability as a data lake storage and greatly improves the availability of its stream pipeline. ...

Continue reading »

Apache Flink Kubernetes Operator 1.3.1 Release Announcement

January 10, 2023 - Gyula Fora (@GyulaFora)

The Apache Flink Community is pleased to announce the first bug fix release of the Flink Kubernetes Operator 1.3 series. The release contains fixes for several critical issues and some major stability improvements for the application upgrade mechanism. We highly recommend all users to upgrade to Flink Kubernetes Operator 1.3.1. Release Notes # Bug # [FLINK-30329] - flink-kubernetes-operator helm chart does not work with dynamic config because of use of volumeMount subPath [FLINK-30361] - Cluster deleted and created back while updating replicas [FLINK-30406] - Jobmanager Deployment error without HA metadata should not lead to unrecoverable error [FLINK-30437] - State incompatibility issue might cause state loss [FLINK-30527] - Last-state suspend followed by flinkVersion change may lead to state loss [FLINK-30528] - Job may be stuck in upgrade loop when last-state fallback is disabled and deployment is missing Improvement # [FLINK-28875] - Add FlinkSessionJobControllerTest [FLINK-30408] - Add unit test for HA metadata check logic Release Resources # The source artifacts and helm chart are available on the Downloads page of the Flink website. ...

Continue reading »

Apache Flink Kubernetes Operator 1.3.0 Release Announcement

December 14, 2022 - Matyas Orhidi (@matyasorhidi) Gyula Fora (@GyulaFora)

The Flink community is happy to announce that the latest Flink Kubernetes Operator version went live today. Beyond the regular operator improvements and fixes the 1.3.0 version also integrates better with some popular infrastructure management tools like OLM and Argo CD. These improvements are clear indicators that the original intentions of the Flink community, namely to provide the de facto standard solution for managing Flink applications on Kubernetes is making steady progress to becoming a reality. ...

Continue reading »

Optimising the throughput of async sinks using a custom RateLimitingStrategy

November 25, 2022 - Hong Liang Teoh

Introduction # When designing a Flink data processing job, one of the key concerns is maximising job throughput. Sink throughput is a crucial factor because it can determine the entire job’s throughput. We generally want the highest possible write rate in the sink without overloading the destination. However, since the factors impacting a destination’s performance are variable over the job’s lifetime, the sink needs to adjust its write rate dynamically. ...

Continue reading »

Apache Flink 1.15.3 Release Announcement

November 10, 2022 - Fabian Paul

The Apache Flink Community is pleased to announce the third bug fix release of the Flink 1.15 series. This release includes 59 bug fixes, vulnerability fixes, and minor improvements for Flink 1.15. 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.15.3. ...

Continue reading »

Announcing the Release of Apache Flink 1.16

October 28, 2022 - Godfrey He (@godfreyhe)

Apache Flink continues to grow at a rapid pace and is one of the most active communities in Apache. Flink 1.16 had over 240 contributors enthusiastically participating, with 19 FLIPs and 1100+ issues completed, bringing a lot of exciting features to the community. Flink has become the leading role and factual standard of stream processing, and the concept of the unification of stream and batch data processing is gradually gaining recognition and is being successfully implemented in more and more companies. ...

Continue reading »