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

内容简介：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]

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持 码农网

查看所有标签

本站部分资源来源于网络，本站转载出于传递更多信息之目的，版权归原作者或者来源机构所有，如转载稿涉及版权问题，请联系我们。