Apache Flink 1.12.3 发布，流处理框架

内容简介：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 函数

详情请查看更新公告。

以上就是本文的全部内容，希望本文的内容对大家的学习或者工作能带来一定的帮助，也希望大家多多支持 码农网

查看所有标签

本站部分资源来源于网络，本站转载出于传递更多信息之目的，版权归原作者或者来源机构所有，如转载稿涉及版权问题，请联系我们。