内容简介:Apache Flink 1.13.2 现已发布,这是 Apache Flink 1.13 系列的第二个错误修复版本,包括 127 个修复和小改进。 主要更新内容 ContinuousFileReaderOperator 不应在 close() 上关闭输出 HiveTableSourceITCase.te...
Apache Flink 1.13.2 现已发布,这是 Apache Flink 1.13 系列的第二个错误修复版本,包括 127 个修复和小改进。
主要更新内容
- ContinuousFileReaderOperator 不应在 close() 上关闭输出
- HiveTableSourceITCase.testPartitionFilter 在 AZP 上失败
- ParquetInputFormat 不应需要 Parquet 模式作为用户输入
- 应用程序模式在构建 PackagedProgram 时不设置配置
- 将所有 “Connection reset by peer” 异常包装为 RemoteTransportException
- 由于 ConcurrentModificationException,KafkaChangelogTableITCase.testKafkaCanalChangelogSource 失败
- 某些场景无法通过配置单元目录删除表
- SequentialChannelStateReaderImpl 可能会回收缓冲区两次
- 在批处理模式下无法执行极长的 sql
- 在 flink-connector-kinesis 中升级 AWS SDK 以包含新区域 af-south-1
- 为 Python Table API 添加 TableResult.collect 的文档
- 支持模式注册表格式的 ssl 连接
- 实现 ParquetAvroInputFormat
- 记录状态访问的延迟跟踪指标
- 在对齐超时时保持通道阻塞
- 为 Kafka 新源添加文档
详情请查看更新公告。
以上所述就是小编给大家介绍的《Apache Flink 1.13.2 发布,流处理框架》,希望对大家有所帮助,如果大家有任何疑问请给我留言,小编会及时回复大家的。在此也非常感谢大家对 码农网 的支持!
猜你喜欢:- 简述大数据实时处理框架
- gobox中的consumer处理框架
- 流式处理框架storm浅析(上篇)
- Bootstrap开发框架界面的调整处理
- iOS换肤功能的简单处理框架
- 一个不错的音视频快速处理框架
本站部分资源来源于网络,本站转载出于传递更多信息之目的,版权归原作者或者来源机构所有,如转载稿涉及版权问题,请联系我们。
Computers and Intractability
M R Garey、D S Johnson / W. H. Freeman / 1979-4-26 / GBP 53.99
This book's introduction features a humorous story of a man with a line of people behind him, who explains to his boss, "I can't find an efficient algorithm, but neither can all these famous people." ......一起来看看 《Computers and Intractability》 这本书的介绍吧!