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 新源添加文档
详情请查看更新公告。
