Apache Flink 1.10.3 发布

来源: OSCHINA
编辑: 局长
2021-01-30 07:49:41

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 能在所有常见集群环境中运行,并能以内存速度和任意规模进行计算。

展开阅读全文
5 收藏
分享
1 评论
5 收藏
分享
返回顶部
顶部
返回顶部
顶部