Apache Flink 1.13.1 发布,流处理框架

来源: 投稿
作者: 御坂弟弟
2021-05-29

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<string,string> 无法转换为数据流的问题
  • 使用保存点停止,对于链接到 MultipleInputStreamTask 的源,drain 不会提前设置水印
  • 修复当 SQL 中的 sum/count 和 avg 同时出现时,SplitAggregateRule 会出现异常的问题
  • 作业完成后,不会删除 leader 和 leaderlatch 下的 Zookeeper 节点
  • 修复 flink-sql-parser 模型类 ParserResource 缺少 ParserResource.properties 的问题
  • 修复在 Web UI 中没有显示 Statebackend 和 CheckpointStorage 类型的问题
  • 重构基于 TVF 窗口的一些接口,以提高可扩展性
  • 从所有 jar 中筛选 maven 元数据

详情请查看更新公告

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