Apache Flink 1.14.6 发布,流处理框架
Apache Flink 1.14.6 现已发布,这是一个错误修复版本。包括针对 Flink 1.14 的 34 个错误修复、漏洞修复和小改进。有关所有更改的完整列表可参阅:JIRA。官方强烈建议所有用户升级到 Flink 1.14.6。 具体更新内容包括: Bug [FLINK-24862]- 用户定义的hive udaf/udtf 不能在 hive dialect 中正常使用 [FLINK-25454]- 吞吐量计算器中的负数时间 [FLINK-27041]- 如果任何主题分区为空,则批处理模式下的 KafkaSource 会失败 [FLINK-27399]- Pulsar 连接器未正确设置开始消耗位置 [FLINK-27418]- Flink SQL TopN 结果是错误的 [FLINK-27683]- 插入到 (column1, column2)Values(.....) 失败,并带有 SQL 提示 [FLINK-27762]- Kafka 在处理 splits changes 时出现 WakeupException [FLINK-28019]- RetractableTopN...
