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.

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()