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 個修復程式和一些小改進，主要新特性與改進如下：

• [ofollow,noindex" target="_blank">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