Apache Flink 1.5.5 Released

The Apache Flink community released the fifth 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.5.

Updated Maven dependencies:

<dependency>
  <groupId>org.apache.flink</groupId>
  <artifactId>flink-java</artifactId>
  <version>1.5.5</version>
</dependency>
<dependency>
  <groupId>org.apache.flink</groupId>
  <artifactId>flink-streaming-java_2.11</artifactId>
  <version>1.5.5</version>
</dependency>
<dependency>
  <groupId>org.apache.flink</groupId>
  <artifactId>flink-clients_2.11</artifactId>
  <version>1.5.5</version>
</dependency>

You can find the binaries on the updated Downloads page.

List of resolved issues:

Sub-task

• [FLINK-10242] - Latency marker interval should be configurable
• [FLINK-10243] - Add option to reduce latency metrics granularity
• [FLINK-10331] - Reduce number of flush requests to the network stack
• [FLINK-10332] - Move data available notification in PipelinedSubpartition out of the synchronized block

Bug

• [FLINK-5542] - YARN client incorrectly uses local YARN config to check vcore capacity
• [FLINK-9567] - Flink does not release resource in Yarn Cluster mode
• [FLINK-9788] - ExecutionGraph Inconsistency prevents Job from recovering
• [FLINK-9884] - Slot request may not be removed when it has already be assigned in slot manager
• [FLINK-9891] - Flink cluster is not shutdown in YARN mode when Flink client is stopped
• [FLINK-9932] - Timed-out TaskExecutor slot-offers to JobMaster leak the slot
• [FLINK-10135] - Certain cluster-level metrics are no longer exposed
• [FLINK-10222] - Table scalar function expression parses error when function name equals the exists keyword suffix
• [FLINK-10259] - Key validation for GroupWindowAggregate is broken
• [FLINK-10316] - Add check to KinesisProducer that aws.region is set
• [FLINK-10354] - Savepoints should be counted as retained checkpoints
• [FLINK-10400] - Return failed JobResult if job terminates in state FAILED or CANCELED
• [FLINK-10415] - RestClient does not react to lost connection
• [FLINK-10451] - TableFunctionCollector should handle the life cycle of ScalarFunction
• [FLINK-10469] - FileChannel may not write the whole buffer in a single call to FileChannel.write(Buffer buffer)
• [FLINK-10487] - fix invalid Flink SQL example
• [FLINK-10516] - YarnApplicationMasterRunner does not initialize FileSystem with correct Flink Configuration during setup
• [FLINK-10524] - MemoryManagerConcurrentModReleaseTest.testConcurrentModificationWhileReleasing failed on travis
• [FLINK-10544] - Remove custom settings.xml for snapshot deployments

Improvement

• [FLINK-10075] - HTTP connections to a secured REST endpoint flood the log
• [FLINK-10260] - Confusing log messages during TaskManager registration
• [FLINK-10282] - Provide separate thread-pool for REST endpoint
• [FLINK-10312] - Wrong / missing exception when submitting job
• [FLINK-10375] - ExceptionInChainedStubException hides wrapped exception in cause
• [FLINK-10582] - Make REST executor thread priority configurable