Apache Flink 1.6.4 Released

The Apache Flink community released the fourth bugfix version of the Apache Flink 1.6 series.

This release includes more than 25 fixes and minor improvements for Flink 1.6.3. The list below includes a detailed list of all fixes.

We highly recommend all users to upgrade to Flink 1.6.4.

Updated Maven dependencies:

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

You can find the binaries on the updated Downloads page.

List of resolved issues:

Bug

• [FLINK-10721] - Kafka discovery-loop exceptions may be swallowed
• [FLINK-10761] - MetricGroup#getAllVariables can deadlock
• [FLINK-10774] - connection leak when partition discovery is disabled and open throws exception
• [FLINK-10848] - Flink's Yarn ResourceManager can allocate too many excess containers
• [FLINK-11022] - Update LICENSE and NOTICE files for older releases
• [FLINK-11071] - Dynamic proxy classes cannot be resolved when deserializing job graph
• [FLINK-11084] - Incorrect ouput after two consecutive split and select
• [FLINK-11119] - Incorrect Scala example for Table Function
• [FLINK-11134] - Invalid REST API request should not log the full exception in Flink logs
• [FLINK-11151] - FileUploadHandler stops working if the upload directory is removed
• [FLINK-11173] - Proctime attribute validation throws an incorrect exception message
• [FLINK-11224] - Log is missing in scala-shell
• [FLINK-11232] - Empty Start Time of sub-task on web dashboard
• [FLINK-11234] - ExternalTableCatalogBuilder unable to build a batch-only table
• [FLINK-11235] - Elasticsearch connector leaks threads if no connection could be established
• [FLINK-11251] - Incompatible metric name on prometheus reporter
• [FLINK-11389] - Incorrectly use job information when call getSerializedTaskInformation in class TaskDeploymentDescriptor
• [FLINK-11584] - ConfigDocsCompletenessITCase fails DescriptionBuilder#linebreak() is used
• [FLINK-11585] - Prefix matching in ConfigDocsGenerator can result in wrong assignments

Improvement

• [FLINK-10910] - Harden Kubernetes e2e test
• [FLINK-11079] - Skip deployment for flnk-storm-examples
• [FLINK-11207] - Update Apache commons-compress from 1.4.1 to 1.18
• [FLINK-11262] - Bump jython-standalone to 2.7.1
• [FLINK-11289] - Rework example module structure to account for licensing
• [FLINK-11304] - Typo in time attributes doc
• [FLINK-11469] - fix Tuning Checkpoints and Large State doc