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
转自 https://www.oschina.net/news/113100/apache-flink-1-9-2-released