Apache Flink 1.12.4 发布，流处理框架

内容简介：Apache Flink 1.12.4 现已发布，这是 Apache Flink 1.12 系列的 bug 修复版本，包含 21 个修复和优化，因此官方强烈建议所有用户都升级到 1.12.4。 优化 在 DataStream API 文档中增加 10 分钟的阅读内容 为新的 ...

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 不能被重启的问题

详情请查看更新公告。

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

查看所有标签

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