Apache Flink 1.3.2发布，通用数据处理平台

Apache Flink 社区发布了 Apache Flink 1.3 系列的第二个 bug 修复版本。此版本包含 60 多个修补程序和基于 Flink 1.3.1 的小小改进，官方表示强烈建议所有用户升级到 Flink 1.3.2。

值得关注的变更：

• Flink Kafka Consumer 0.10 的默认 Kafka 版本从 0.10.0.1 升级到 0.10.2.1

• Flink Kinesis Consumer AWS API 调用行为配置的一些默认值适用于更好的默认消费性能：1) SHARD_GETRECORDS_MAX 默认值变更为 10,000
  2) SHARD_GETRECORDS_INTERVAL_MILLIS 默认值变更为200ms

更新：

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

更多内容请参阅发布主页。

下载地址