Apache Flink 1.5.2 Released

July 31, 2018 -

The Apache Flink community released the second bugfix version of the Apache Flink 1.5 series. This release includes more than 20 fixes and minor improvements for Flink 1.5.1. The list below includes a detailed list of all fixes. We highly recommend all users to upgrade to Flink 1.5.2. Updated Maven dependencies: <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-java</artifactId> <version>1.5.2</version> </dependency> <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-streaming-java_2.11</artifactId> <version>1.5.2</version> </dependency> <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-clients_2.11</artifactId> <version>1.5.2</version> </dependency> You can find the binaries on the updated Downloads page. ...

Continue reading »

Apache Flink 1.5.1 Released

July 12, 2018 -

The Apache Flink community released the first bugfix version of the Apache Flink 1.5 series. This release includes more than 60 fixes and minor improvements for Flink 1.5.0. The list below includes a detailed list of all fixes. We highly recommend all users to upgrade to Flink 1.5.1. Updated Maven dependencies: <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-java</artifactId> <version>1.5.1</version> </dependency> <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-streaming-java_2.11</artifactId> <version>1.5.1</version> </dependency> <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-clients_2.11</artifactId> <version>1.5.1</version> </dependency> You can find the binaries on the updated Downloads page. ...

Continue reading »

Apache Flink 1.5.0 Release Announcement

May 18, 2018 - Fabian Hueske (@fhueske)

The Apache Flink community is thrilled to announce the 1.5.0 release. Over the past 5 months, the Flink community has been working hard to resolve more than 780 issues. Please check the complete changelog for more detail. Flink 1.5.0 is the sixth major release in the 1.x.y series. As usual, it is API-compatible with previous 1.x.y releases for APIs annotated with the @Public annotation. We encourage everyone to download the release and check out the documentation. ...

Continue reading »

Apache Flink 1.3.3 Released

March 15, 2018 -

The Apache Flink community released the third bugfix version of the Apache Flink 1.3 series. This release includes 4 critical fixes related to checkpointing and recovery. The list below includes a detailed list of all fixes. We highly recommend all Flink 1.3 series users to upgrade to Flink 1.3.3. Updated Maven dependencies: <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-java</artifactId> <version>1.3.3</version> </dependency> <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-streaming-java_2.10</artifactId> <version>1.3.3</version> </dependency> <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-clients_2.10</artifactId> <version>1.3.3</version> </dependency> You can find the binaries on the updated Downloads page. ...

Continue reading »

Apache Flink 1.4.2 Released

March 8, 2018 -

The Apache Flink community released the second bugfix version of the Apache Flink 1.4 series. This release includes more than 10 fixes and minor improvements for Flink 1.4.1. The list below includes a detailed list of all fixes. We highly recommend all users to upgrade to Flink 1.4.2. Updated Maven dependencies: <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-java</artifactId> <version>1.4.2</version> </dependency> <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-streaming-java_2.11</artifactId> <version>1.4.2</version> </dependency> <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-clients_2.11</artifactId> <version>1.4.2</version> </dependency> You can find the binaries on the updated Downloads page. ...

Continue reading »

An Overview of End-to-End Exactly-Once Processing in Apache Flink (with Apache Kafka, too!)

February 28, 2018 - Piotr Nowojski (@PiotrNowojski) Mike Winters (@wints)

This post is an adaptation of Piotr Nowojski’s presentation from Flink Forward Berlin 2017. You can find the slides and a recording of the presentation on the Flink Forward Berlin website. Apache Flink 1.4.0, released in December 2017, introduced a significant milestone for stream processing with Flink: a new feature called TwoPhaseCommitSinkFunction (relevant Jira here) that extracts the common logic of the two-phase commit protocol and makes it possible to build end-to-end exactly-once applications with Flink and a selection of data sources and sinks, including Apache Kafka versions 0. ...

Continue reading »

Apache Flink 1.4.1 Released

February 15, 2018 -

The Apache Flink community released the first bugfix version of the Apache Flink 1.4 series. This release includes more than 60 fixes and minor improvements for Flink 1.4.0. The list below includes a detailed list of all fixes. We highly recommend all users to upgrade to Flink 1.4.1. Updated Maven dependencies: <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-java</artifactId> <version>1.4.1</version> </dependency> <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-streaming-java_2.11</artifactId> <version>1.4.1</version> </dependency> <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-clients_2.11</artifactId> <version>1.4.1</version> </dependency> You can find the binaries on the updated Downloads page. ...

Continue reading »

Managing Large State in Apache Flink: An Intro to Incremental Checkpointing

January 30, 2018 - Stefan Ricther (@StefanRRicther) Chris Ward (@chrischinch)

Apache Flink was purpose-built for stateful stream processing. However, what is state in a stream processing application? I defined state and stateful stream processing in a previous blog post, and in case you need a refresher, state is defined as memory in an application’s operators that stores information about previously-seen events that you can use to influence the processing of future events. State is a fundamental, enabling concept in stream processing required for a majority of complex use cases. ...

Continue reading »

Apache Flink in 2017: Year in Review

December 21, 2017 - Chris Ward (@chrischinch) Mike Winters (@wints)

2017 was another exciting year for the Apache Flink® community, with 3 major version releases (Flink 1.2.0 in February, Flink 1.3.0 in June, and Flink 1.4.0 in December) and the first-ever Flink Forward in San Francisco, giving Flink community members in another corner of the globe an opportunity to connect. Users shared details about their innovative production deployments, redefining what is possible with a modern stream processing framework like Flink. ...

Continue reading »

Apache Flink 1.4.0 Release Announcement

December 12, 2017 - Aljoscha Krettek (@aljoscha) Mike Winters (@wints)

The Apache Flink community is pleased to announce the 1.4.0 release. Over the past 5 months, the Flink community has been working hard to resolve more than 900 issues. See the complete changelog for more detail. This is the fifth major release in the 1.x.y series. It is API-compatible with the other 1.x.y releases for APIs annotated with the @Public annotation. We encourage everyone to download the release and check out the documentation. ...

Continue reading »