Apache Flink 1.13.1 发布，流处理框架

内容简介：Apache Flink 1.13.1 现已发布，这是 Apache Flink 1.13 系列的首个 bug 修复版本，包含 82 个修复和优化，因此官方强烈建议所有用户都升级到 1.13.1。 主要更新内容 修复在 TIMESTAMP_LTZ 列上声明 SOURCE_WATER...

Apache Flink 1.13.1 现已发布，这是 Apache Flink 1.13 系列的首个 bug 修复版本，包含 82 个修复和优化，因此官方强烈建议所有用户都升级到 1.13.1。

主要更新内容

• 修复在 TIMESTAMP_LTZ 列上声明 SOURCE_WATERMARK 时类型不匹配的问题
• 使结构化类型的字段在构造过程中更加宽松
• 启用对象重用时，AsyncWaitOperator 应深度复制 StreamElement
• 修复无法通过使用 kinesis 消费者的保存点停止流媒体工作的问题
• 修复 flink iceberg table map 无法转换为数据流的问题
• 使用保存点停止，对于链接到 MultipleInputStreamTask 的源，drain 不会提前设置水印
• 修复当 SQL 中的 sum/count 和 avg 同时出现时，SplitAggregateRule 会出现异常的问题
• 作业完成后，不会删除 leader 和 leaderlatch 下的 Zookeeper 节点
• 修复 flink-sql-parser 模型类 ParserResource 缺少 ParserResource.properties 的问题
• 修复在 Web UI 中没有显示 Statebackend 和 CheckpointStorage 类型的问题
• 重构基于 TVF 窗口的一些接口，以提高可扩展性
• 从所有 jar 中筛选 maven 元数据

详情请查看更新公告。

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持 码农网

查看所有标签

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