Apache Flink 1.5.2 Released

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.

List of resolved issues:

Sub-task

• [FLINK-9839] - End-to-end test: Streaming job with SSL

Bug

• [FLINK-5750] - Incorrect translation of n-ary Union
• [FLINK-8161] - Flakey YARNSessionCapacitySchedulerITCase on Travis
• [FLINK-8731] - TwoInputStreamTaskTest flaky on travis
• [FLINK-9091] - Failure while enforcing releasability in building flink-json module
• [FLINK-9380] - Failing end-to-end tests should not clean up logs
• [FLINK-9439] - DispatcherTest#testJobRecovery dead locks
• [FLINK-9575] - Potential race condition when removing JobGraph in HA
• [FLINK-9584] - Unclosed streams in Bucketing-/RollingSink
• [FLINK-9658] - Test data output directories are no longer cleaned up
• [FLINK-9706] - DispatcherTest#testSubmittedJobGraphListener fails on Travis
• [FLINK-9743] - PackagedProgram.extractContainedLibraries fails on Windows
• [FLINK-9754] - Release scripts refers to non-existing profile
• [FLINK-9755] - Exceptions in RemoteInputChannel#notifyBufferAvailable() are not propagated to the responsible thread
• [FLINK-9762] - CoreOptions.TMP_DIRS wrongly managed on Yarn
• [FLINK-9766] - Incomplete/incorrect cleanup in RemoteInputChannelTest
• [FLINK-9771] - "Show Plan" option under Submit New Job in WebUI not working
• [FLINK-9772] - Documentation of Hadoop API outdated
• [FLINK-9784] - Inconsistent use of 'static' in AsyncIOExample.java
• [FLINK-9793] - When submitting a flink job with yarn-cluster, flink-dist*.jar is repeatedly uploaded
• [FLINK-9810] - JarListHandler does not close opened jars
• [FLINK-9838] - Slot request failed Exceptions after completing a job
• [FLINK-9841] - Web UI only show partial taskmanager log
• [FLINK-9842] - Job submission fails via CLI with SSL enabled
• [FLINK-9847] - OneInputStreamTaskTest.testWatermarksNotForwardedWithinChainWhenIdle unstable
• [FLINK-9857] - Processing-time timers fire too early
• [FLINK-9860] - Netty resource leak on receiver side
• [FLINK-9872] - SavepointITCase#testSavepointForJobWithIteration does not properly cancel jobs
• [FLINK-9908] - Inconsistent state of SlotPool after ExecutionGraph cancellation
• [FLINK-9910] - Non-queued scheduling failure sometimes does not return the slot
• [FLINK-9911] - SlotPool#failAllocation is called outside of main thread

New Feature

• [FLINK-9499] - Allow REST API for running a job to provide job configuration as body of POST request

Improvement

• [FLINK-9659] - Remove hard-coded sleeps in bucketing sink E2E test
• [FLINK-9748] - create_source_release pollutes flink root directory
• [FLINK-9768] - Only build flink-dist for binary releases
• [FLINK-9785] - Add remote addresses to LocalTransportException instances
• [FLINK-9801] - flink-dist is missing dependency on flink-examples
• [FLINK-9804] - KeyedStateBackend.getKeys() does not work on RocksDB MapState
• [FLINK-9811] - Add ITCase for interactions of Jar handlers
• [FLINK-9873] - Log actual state when aborting checkpoint due to task not running
• [FLINK-9881] - Typo in a function name in table.scala
• [FLINK-9888] - Remove unsafe defaults from release scripts
• [FLINK-9909] - Remove cancellation of input futures from ConjunctFutures