Apache Flink 1.5.5 和 1.6.2 发布，通用数据处理平台

Apache Flink 1.5.5 和 1.6.2 发布了。Apache Flink 是一个开源的流处理框架，应用于分布式、高性能、始终可用的、准确的数据流应用程序。Apache Flink 也是高效和分布式的通用数据处理平台。Apache Flink 声明式的数据分析开源系统，结合了分布式 MapReduce 类平台的高效，灵活的编程和扩展性。同时在并行数据库发现查询优化方案。

1.5.5 是 Apache Flink 1.5 系列的第五个 bugfix 版本，包括超过 20 个修复程序和一些小改进，强烈建议所有用户升级到 Flink 1.5.5，主要改进如下：

改进

• [ 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

Maven

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

详细内容请查看发布说明 。

1.6.2 是 Apache Flink 1.6 系列的第二个 bugfix 版本，包括超过 30 个修复程序和一些小改进，强烈建议所有用户升级到 Flink 1.6.2，主要改进如下：

改进

• [ FLINK-9061 ] - Add entropy to s3 path for better scalability

• [ 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-10291 ] - Generate JobGraph with fixed/configurable JobID in StandaloneJobClusterEntrypoint

• [ FLINK-10311 ] - HA end-to-end/Jepsen tests for standby Dispatchers

• [ FLINK-10312 ] - Wrong / missing exception when submitting job

• [ FLINK-10371 ] - Allow to enable SSL mutual authentication on REST endpoints by configuration

• [ FLINK-10375 ] - ExceptionInChainedStubException hides wrapped exception in cause

• [ FLINK-10582 ] - Make REST executor thread priority configurable

Maven

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

详情请查看发布说明 。

下载地址： http://flink.apache.org/downloads.html