Apache Flink 1.3.3 Released

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

List of resolved issues:

Sub-task

  • [FLINK-7783] - Don't always remove checkpoints in ZooKeeperCompletedCheckpointStore#recover()

Bug

  • [FLINK-7283] - PythonPlanBinderTest issues with python paths
  • [FLINK-8487] - State loss after multiple restart attempts
  • [FLINK-8807] - ZookeeperCompleted checkpoint store can get stuck in infinite loop

Improvement

  • [FLINK-8890] - Compare checkpoints with order in CompletedCheckpoint.checkpointsMatch()