Apache Flink 1.3.2 发布,通用数据处理平台 - 开源中国社区
Apache Flink 1.3.2 发布,通用数据处理平台
局长 2017年08月06日

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

局长 局长 发布于2017年08月06日 收藏 10

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>

更多内容请参阅发布主页

下载地址

本站文章除注明转载外,均为本站原创或编译。欢迎任何形式的转载,但请务必注明出处,尊重他人劳动共创开源社区。
转载请注明:文章转载自 开源中国社区 [http://www.oschina.net]
本文标题:Apache Flink 1.3.2 发布,通用数据处理平台
分享
评论(0)
最新评论
顶部