Apache Flink 1.13.2 发布,流处理框架

栏目: 软件资讯 · 发布时间: 3年前

内容简介: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 发布,流处理框架》,希望对大家有所帮助,如果大家有任何疑问请给我留言,小编会及时回复大家的。在此也非常感谢大家对 码农网 的支持!

查看所有标签

猜你喜欢:

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

Computers and Intractability

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》 这本书的介绍吧!

Base64 编码/解码
Base64 编码/解码

Base64 编码/解码

SHA 加密
SHA 加密

SHA 加密工具

UNIX 时间戳转换
UNIX 时间戳转换

UNIX 时间戳转换