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]- RetractableTopNFunction 在启用状态 ttl 的情况下收回 stale record 时出现错误
  • [FLINK-28057]- LD_PRELOAD 在 flink-docker 上硬编码为x64
  • [FLINK-28357]- 恢复 Finished sources 时的水印问题
  • [FLINK-28454]- 修复了 KafkaSource 的错误时间戳示例
  • [FLINK-28609]- Flink-Pulsar 连接器在较大的架构上失败
  • [FLINK-28880]- 修复了 CEP 文档中关于循环模式的严格连续的错误结果
  • [FLINK-28908]- 在 PyFlink 中,LIST 类型的编码选择不正确。
  • [FLINK-28978]- Kinesis 连接器不适用于新的 AWS 区域
  • [FLINK-29130]- 纠正文档中对 state.backend.local-recovery 的描述
  • [FLINK-29138]- Project pushdown 不适用于 lookup source

Improvement

  • [FLINK-27865]- 添加在 Kafka SQL 连接器文档中配置 SASL 和 SSL 的指南和示例
  • [FLINK-28094]- 升级 AWS SDK 以支持 ap-southeast-3

发布公告:https://flink.apache.org/news/2022/09/28/release-1.14.6.html 


相關推薦

2022-08-26

Apache Flink 1.15.2 现已发布,这是 Flink 1.15 系列的第二个错误修复版本;此版本包括 30 个错误修复、漏洞修复和 Flink 1.15 相关的一些小改进。Apache Flink 是一个开源的流处理框架,适用于分布式、高性能的数据流应用。 具体更

2023-04-27

来源 | Apache Flink 官方博客 翻译 | 林东 Apache Flink 社区很荣幸地宣布 Apache Flink ML 2.2.0 版本正式发布!本次发布的版本重点添加了 Flink ML 中的特征工程算法。现在 Flink ML 包含了 33 个开箱可用的特征工程算法,可以支持很多

2022-11-03

Apache Flink 持续保持高速发展,是 Apache 最活跃的社区之一。Flink 1.16 共有 240 多个 Contributor 热情参与,共完成了 19 个 FLIP [1] 和 1100 多个 issue,给社区带来非常多振奋人心的功能。 Flink 已经是流计算领域的领跑者,流

2022-09-14

的工具包和运行时。该项目宣布了许可证的变更,由 Apache 2.0 更换为 BSL v1.1(Business Source License)。BSL 是一个 "源代码可用" 的许可证,未来开发者如需在生产中使用 Akka(2.7+ 版本)都需要获得 Lightbend 公司的商业许可。但 Ak

2023-04-28

Apache StreamPark(incubating) 是一个流处理应用程序开发管理框架。初衷是让流处理更简单,旨在轻松构建和管理流处理应用程序,提供使用 Apache Flink 和 Apache Spark 等编写流处理应用程序的开发框架。同时,StreamPark 提供了一个流

2022-09-10

p;月 1 号顺利通过投票,正式成为全球最大的开源基金会 Apache 软件基金会 (ASF) 的孵化项目。这是 StreamPark 项目的新起点,意味着开源社区化协作将会变得更加规范以及国际化。   什么是 StreamPark StreamPark 原名 Strea

2023-05-05

友们大家好: 关于近日 "赤兔" 实时计算平台违规使用 Apache  StreamPark (Incubating) 代码一事[1], 赤兔开发团队已经重新按照 Apache 的合规要求, 更新了相关代码, 并且公开在官网[2] 做出了道歉声明: 在 Github[3]

2022-10-10

项目名称 数据集成 airbytehq/airbyte alibaba/DataX apache/camel apache/flume apache/incubator-seatunnel apache/inlong apache/sqoop dbt-labs/dbt-core debezium/debezium ververica/flink-cdc-connectors 流处理 apache/beam apache/flink apache/incubator-heron apache/i

2023-08-25

参与到社区的建设。参考攻略:保姆级教程:如何成为 Apache Linkis 文档贡献者   2 ► 代码贡献。我们梳理了社区中简单并且容易入门的的任务,非常适合新人做代码贡献。请查阅新手任务列表:https://github.com/apache/in

2023-03-30

的监控指标等,具体的使用方式可以参考 https://seatunnel.apache.org/docs/seatunnel-engine/rest-api/ 02 AI Compatible SeaTunnel 2.3.1 当中重构了Http接口和相关API,根据现有xGPT水平能力简化了SaaS Connector相关API和Connector构建流程,让ChatGPT 4.0

2023-09-26

快速、安全 bboss --- 简化版 Flink,一个基于开源协议 Apache License 发布的开源项目,由开源团队 bboss 运维,主要由以下三部分构成: Elasticsearch Highlevel Java Restclient , 一个高性能高兼容性的 Elasticsearch/Opensearch jav

2023-10-10

Apache Hudi 0.14.0 现已发布。公告指出,该版本标志着一个重要的里程碑,具有一系列新功能和增强功能。其中包括引入Record Level Index、自动生成记录键 、用于增量读取的 hudi_table_changes函数等等。 值得注意的是,此版本还

2022-07-28

两个月前,Apache Flink 推出第一个可用于生产环境的 Apache Flink Kubernetes Operator 版本以来(1.0 版本),社区一直在努力改善该工具的功能。 随着 Flink Kubernetes Operator 1.1 的发布,新版本又带来了一些新功能,改善了生产环境中管理

2022-04-07

一、背景 Apache Flink 作为新一代的实时计算框架已经被应用到各个行业与领域,虽说应用程度不同,但都会遇到一些使用上的痛点,基础的应用痛点比如 FlinkSQL 作业提交不友好、作业无监控报警等。很大程度上说,FlinkSQL 大大