内容简介：Apache Flink 1.6.1 发布了，Apache Flink 是一个开源的流处理框架，应用于分布式、高性能、始终可用的、准确的数据流应用程序。 这是 1.6 系列的第一个 bugfix 版本，此版本包括 60 个修复程序和一些小改进，主要...
Apache Flink 1.6.1 发布了，Apache Flink 是一个开源的流处理框架，应用于分布式、高性能、始终可用的、准确的数据流应用程序。
这是 1.6 系列的第一个 bugfix 版本，此版本包括 60 个修复程序和一些小改进，主要新特性与改进如下：
[FLINK-10022] - 新增输入/输出缓冲区指标
[FLINK-9859] - 更多的 Akka 配置项
[FLINK-9899] - 添加更多指标到 Kinesis 源连接器
[FLINK-9962] - 允许用户在 DateTimeBucketer 中指定 TimeZone
[FLINK-10006] - 改进BarrierBuffer中的日志记录
[FLINK-10020] - Kinesis Consumer listShards 应支持更多可恢复的异常
[FLINK-10082] - 在 Slf4jReporter 中初始化 StringBuilder 并估计大小
[FLINK-10170] - 支持基于描述符的表 API 中的映射和数组类型的字符串表示
[FLINK-10185] - 使 ZooKeeperStateHandleStore＃releaseAndTryRemove 同步
[FLINK-10325] - [State TTL] 重构 TtlListState 只使用循环，没有 Java 流 API 来提高性能
详情见发布公告。
下载地址：http://flink.apache.org/downloads.html
【声明】文章转载自：开源中国社区 [http://www.oschina.net]
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持 码农网
本站部分资源来源于网络，本站转载出于传递更多信息之目的，版权归原作者或者来源机构所有，如转载稿涉及版权问题，请联系我们。
