Apache Flink 1.5.4 Released

September 20, 2018 -

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

Continue reading »

Apache Flink 1.6.1 Released

September 20, 2018 -

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

Continue reading »

Apache Flink 1.5.3 Released

August 21, 2018 -

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

Continue reading »

Apache Flink 1.6.0 Release Announcement

August 9, 2018 - Till Rohrmann (@stsffap)

The Apache Flink community is proud to announce the 1.6.0 release. Over the past 2 months, the Flink community has worked hard to resolve more than 360 issues. Please check the complete changelog for more details. Flink 1.6.0 is the seventh major release in the 1.x.y series. 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.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 »