Apache Flink 1.13.2 发布,流处理框架

来源: 投稿
作者: 御坂弟弟
2021-08-07 09:10:51

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 新源添加文档

详情请查看更新公告

展开阅读全文
3 收藏
分享
0 评论
3 收藏
分享
返回顶部
顶部