Apache Flink 1.10.3 已发布,这是 Apache Flink 1.10 系列的第三个 Bugfix 版本,总共包含 36 个修复程序以及针对 Flink 1.10.2 的小改进。官方强烈建议所有用户升级到 Flink 1.10.3。
Maven
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-java</artifactId>
<version>1.10.3</version>
</dependency>
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-streaming-java_2.11</artifactId>
<version>1.10.3</version>
</dependency>
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-clients_2.11</artifactId>
<version>1.10.3</version>
</dependency>
注意事项:由于项目空间限制,PyPI 上暂时缺少 Apache Flink 1.10.3 的源码包。目前,有关增加空间限制的请求正在由 PyPI 审核。在这段时间内,可以根据需要手动构建软件包。
部分更新内容
改进
- [FLINK-16753] - 来自 AsyncCheckpointRunnable 的异常已变更为被封装在 CheckpointException 中
- [FLINK-18287] - 修正 SQL 页面中的 Python Table API 文档
- [FLINK-19055] - MemoryManagerSharedResourcesTest 包含三个运行时间非常长的测试
- [FLINK-19105] - 改正 Table API 的错误示例代码
- [FLINK-19252] - 在 io.tmp.dirs 下创建 Jaas 文件,如果不存在则不创建文件夹
- [FLINK-19339] - 支持具有逻辑类型的 Avro 联合
- [FLINK-19523] - 隐藏敏感的命令行配置
详情查看 https://flink.apache.org/news/2021/01/29/release-1.10.3.html
下载地址 https://flink.apache.org/downloads.html
Apache Flink 是一个框架和分布式处理引擎,用于在无边界和有边界数据流上进行有状态的计算。Flink 能在所有常见集群环境中运行,并能以内存速度和任意规模进行计算。