Apache Flink 1.9.2 發佈,流處理框架

Apache Flink 1.9.2 發佈了,Apache Flink 項目的目標是開發一個流處理系統,以統一和支持多種形式的實時和離線數據處理應用程序以及事件驅動的應用程序。

此版本帶來大量 bug 修復,摘取部分如下:

Bug

  • [FLINK-10377] - 刪除 TwoPhaseCommitSinkFunction.notifyCheckpointComplete 中的前提條件
  • [FLINK-10435] - Ctrl + C 之後客戶端偶爾會掛起
  • [FLINK-11120] - TIMESTAMPADD 函數無法正確處理 TIME
  • [FLINK-11835] - ZooKeeperLeaderElectionITCase.testJobExecutionOnClusterWithLeaderChange 失敗
  • [FLINK-12342] - Yarn 資源管理器獲取太多的容器
  • [FLINK-12399] - FilterableTableSource 在作業運行時不使用過濾器
  • [FLINK-13184] - 啟動 TaskExecutor 會阻止 YarnResourceManager 的主線程
  • [FLINK-13589] - 具有整個文件輸入拆分的多字節定界符上的 DelimitedInputFormat 索引錯誤
  • [FLINK-13702] - 在 Travis 上 BaseMapSerializerTest.testDuplicate 失敗
  • ……

更新說明:https://flink.apache.org/news/2020/01/30/release-1.9.2.html


文章轉載自 OSCHINA 社區 [http://www.oschina.net]

本文標題:Apache Flink 1.9.2 發佈,流處理框架

本文地址:https://www.oschina.net/news/113100/apache-flink-1-9-2-released


分享到:


相關文章: