Apache Flink 1.12.3 发布,流处理框架

来源: 投稿
作者: 御坂弟弟
2021-04-30

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 函数

详情请查看更新公告

展开阅读全文
3 收藏
分享
加载中
1 评论
3 收藏
分享
返回顶部
顶部