Apache Flink 1.13.2 发布,流处理框架
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-c...