Apache Flink 1.6.1 发布,新增输入/输出缓冲区指标
来自:www.oschina.net 收录时间:2018-09-21
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
阅读更多