Apache Flink 1.7.1 Released

The Apache Flink community released the first bugfix version of the Apache Flink 1.7 series.

This release includes 27 fixes and minor improvements for Flink 1.7.0. The list below includes a detailed list of all fixes.

We highly recommend all users to upgrade to Flink 1.7.1.

Updated Maven dependencies:

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

You can find the binaries on the updated Downloads page.

List of resolved issues:

Sub-task

• [FLINK-10252] - Handle oversized metric messages
• [FLINK-10367] - Avoid recursion stack overflow during releasing SingleInputGate
• [FLINK-10522] - Check if RecoverableWriter supportsResume and act accordingly.
• [FLINK-10963] - Cleanup small objects uploaded to S3 as independent objects

Bug

• [FLINK-8336] - YarnFileStageTestS3ITCase.testRecursiveUploadForYarnS3 test instability
• [FLINK-9646] - ExecutionGraphCoLocationRestartTest.testConstraintsAfterRestart failed on Travis
• [FLINK-10149] - Fink Mesos allocates extra port when not configured to do so.
• [FLINK-10359] - Scala example in DataSet docs is broken
• [FLINK-10482] - java.lang.IllegalArgumentException: Negative number of in progress checkpoints
• [FLINK-10566] - Flink Planning is exponential in the number of stages
• [FLINK-10997] - Avro-confluent-registry does not bundle any dependency
• [FLINK-11011] - Elasticsearch 6 sink end-to-end test unstable
• [FLINK-11013] - Fix distinct aggregates for group window in Table API
• [FLINK-11017] - Time interval for window aggregations in SQL is wrongly translated if specified with YEAR_MONTH resolution
• [FLINK-11029] - Incorrect parameter in Working with state doc
• [FLINK-11032] - Elasticsearch (v6.3.1) sink end-to-end test unstable on Travis
• [FLINK-11033] - Elasticsearch (v6.3.1) sink end-to-end test unstable on Travis
• [FLINK-11041] - ReinterpretDataStreamAsKeyedStreamITCase.testReinterpretAsKeyedStream failed on Travis
• [FLINK-11044] - RegisterTableSink docs incorrect
• [FLINK-11045] - UserCodeClassLoader has not been set correctly for RuntimeUDFContext in CollectionExecutor
• [FLINK-11047] - CoGroupGroupSortTranslationTest does not compile with scala 2.12
• [FLINK-11085] - NoClassDefFoundError in presto-s3 filesystem
• [FLINK-11087] - Broadcast state migration Incompatibility from 1.5.3 to 1.7.0
• [FLINK-11094] - Restored state in RocksDBStateBackend that has not been accessed in restored execution causes NPE on snapshot
• [FLINK-11123] - Missing import in ML quickstart docs
• [FLINK-11136] - Fix the logical of merge for DISTINCT aggregates

Improvement

• [FLINK-11080] - Define flink-connector-elasticsearch6 uber-jar dependencies via artifactSet