Apache Flink 1.6.1 发布，新增输入/输出缓冲区指标

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