Apache Flink 1.12.4 发布,流处理框架

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

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

优化

  • 在 DataStream API 文档中增加 10 分钟的阅读内容
  • 为新的 Kafka 源添加端到端测试案例
  • 在某些情况下,编译作业时遇到的异常的根本原因没有暴露给用户
  • 重构 Python 依赖性管理文档
  • 添加缺少的关于 PyFlink 的命令行选项的文档
  • 过滤所有 jar 中的 maven 元数据

Bug 修复

  • 无法通过使用 kinesis 消费者的 savepoint 停止流媒体工作
  • 修复一些与 KafkaSource 相关的bug
  • 修复取消通过定时器输出数据时,缓冲池被破坏的问题
  • 如果嵌套函数的参数数不正确,会出现误导性的异常信息
  • 修复 UnalignedCheckpointITCase 在 zure 上挂起的问题
  • 写入已经释放的缓冲区可能会在工作故障转移/取消期间造成数据损坏
  • 为 Async IO 添加 numRecordsOut 指标
  • 使用 scala api 来改变 PatternStream 的 TimeCharacteristic 是无效的
  • 修复 flink-python jars 中的 LGPL-2.1 文件
  • 修复 Japicmp 在 1.12 分支上失效的问题
  • 修复 KubernetesLeaderElectionAndRetrievalITCase 出现故障的问题
  • 修复 JobMaster 不能被重启的问题

详情请查看更新公告

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