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