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

h4cd
 h4cd
发布于 2018年09月21日
收藏 4

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]
本文标题:Apache Flink 1.6.1 发布,新增输入/输出缓冲区指标
加载中
返回顶部
顶部