Apache Flink 1.12 系列的首个 bug 修复版本 1.12.1 已经发布。该版本包含 79 个修复和优化，因此官方强烈建议所有用户都升级到 1.12.1。

Maven 依赖

<dependency>
  <groupId>org.apache.flink</groupId>
  <artifactId>flink-java</artifactId>
  <version>1.12.1</version>
</dependency>
<dependency>
  <groupId>org.apache.flink</groupId>
  <artifactId>flink-streaming-java_2.11</artifactId>
  <version>1.12.1</version>
</dependency>
<dependency>
  <groupId>org.apache.flink</groupId>
  <artifactId>flink-clients_2.11</artifactId>
  <version>1.12.1</version>
</dependency>

注意事项

• Apache Flink 1.12.1 的 DockerHub 官方映像暂时丢失。作为替代，这些映像目前放在 Flink PMC 的托管仓库中。这也是目前 Native Kubernetes 部署的默认设置。 Flink PMC 将继续与 DockerHub 团队合作以提供官方映像。
• 由于项目空间限制，PyPI 上暂时缺少 Apache Flink 1.12.1 的源代码和 python 3.8 linux wheel 软件包。目前，有关增加空间限制的请求正在 PyPI 审核过程中。在这段时间内，用户可以根据需要手动构建软件包。

部分更新内容

• Sub-task
  • 添加有关 maxwell-json 格式的文档
  • 重做命令行接口文档页面
  • 重做 PyFlink CLI 文档 
• Bug
  • BlobClientTest.testGetFailsDuringStreamingForJobPermanentBlob 挂起
  • 使用 Class.forName 时加载不同的驱动程序类时出现死锁 
  • 由于超时而无法初始化 logger：引发 LoggerInitializationException 
  • 修复 ignore-parse-errors 不适用于旧版 JSON 格式 
  • ZooKeeper quorum 因缺少 log4j 库而无法开始
• Improvement
  • 日志开始/结束状态恢复
  • 将 “Flink Architecture” 页面翻译成中文 
  • 默认情况下启用 log4j2 监视间隔 

详情请查看更新公告。