内容简介：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 不能被重启的问题
详情请查看更新公告。
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持 码农网
猜你喜欢:
- 简述大数据实时处理框架
- gobox中的consumer处理框架
- 流式处理框架storm浅析（上篇）
- Bootstrap开发框架界面的调整处理
- iOS换肤功能的简单处理框架
- 一个不错的音视频快速处理框架
本站部分资源来源于网络，本站转载出于传递更多信息之目的，版权归原作者或者来源机构所有，如转载稿涉及版权问题，请联系我们。
