Apache Flink 1.12.3 现已发布,这是 Apache Flink 1.12 系列的 bug 修复版本,包含 73 个修复和优化,因此官方强烈建议所有用户都升级到 1.12.3。
优化
- 在 Datadog 报告中添加柱状图支持
- 独立 K8s 文档现在会解释备用 JobManagers 的用法
- 优化打印 K8s 规格
- 删除 CheckpointConfig 中的冗余 tolerableCheckpointFailureNumber 设置
- 强化 JobMaster#updateTaskExecutionState()
- 删除用于 AZP 运行的 Kafka 连接器的控制台日志记录
- 进行早期检查以确保结果的长度与 Pandas UDF 的输入相同
Bug 修复
- 修复 CoordinatorEventsExactlyOnceITCase.checkListContainsSequence 在 CI 上失败的问题
- 修复批处理作业由于网络堆栈中的异常而失败的问题
- 未对齐的检查点恢复可能会导致数据流损坏
- HiveTableSink 在将 RowData 转换为 Row 时应复制记录
- FailureRateRestartBackoffTimeStrategy 允许的重启次数少于配置的重启次数
- 无法读取位置路径包含逗号的配置单元表 / 分区
- AvroFileFormatFactory 使用不可反序列化的 lambda 函数
详情请查看更新公告。