Apache Flink 1.3.2 发布，通用数据处理平台
发布于 2017-08-06 00:55:29 | 153 次阅读 | 评论: 0 | 来源: 网友投递
Apache Flink 通用数据处理平台
Apache Flink 声明式的数据分析开源系统，结合了分布式 MapReduce 类平台的高效，灵活的编程和扩展性。同时在并行数据库发现查询优化方案。
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>
更多内容请参阅发布主页。
历史版本 :
Apache Flink 1.4.0 发布，通用数据处理平台
Apache Flink 1.3.2 发布，通用数据处理平台
Apache Flink 1.3.1 发布，通用数据处理平台
Apache Flink 1.3.0 发布，通用数据处理平台
Apache Flink 1.0.0 发布，通用数据处理平台
推荐阅读
最新资讯