内容简介:Apache Flink 1.12.3 现已发布,这是 Apache Flink 1.12 系列的 bug 修复版本,包含 73 个修复和优化,因此官方强烈建议所有用户都升级到 1.12.3。 优化 在 Datadog 报告中添加柱状图支持 独立 K8s 文档现在会解释...
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 函数
详情请查看更新公告。
以上就是本文的全部内容,希望本文的内容对大家的学习或者工作能带来一定的帮助,也希望大家多多支持 码农网
猜你喜欢:- 简述大数据实时处理框架
- gobox中的consumer处理框架
- 流式处理框架storm浅析(上篇)
- Bootstrap开发框架界面的调整处理
- iOS换肤功能的简单处理框架
- 一个不错的音视频快速处理框架
本站部分资源来源于网络,本站转载出于传递更多信息之目的,版权归原作者或者来源机构所有,如转载稿涉及版权问题,请联系我们。