Apache Flink Documentation

Apache Flink® - 数据流上的有状态计算 #

所有流式场景
  • 事件驱动应用
  • 流批分析
  • 数据管道 & ETL
了解更多
正确性保证
  • Exactly-once 状态一致性
  • 事件时间处理
  • 成熟的迟到数据处理
了解更多
分层 API
  • SQL on Stream & Batch Data
  • DataStream API & DataSet API
  • ProcessFunction (Time & State)
了解更多
聚焦运维
  • 灵活部署
  • 高可用
  • 保存点
了解更多
大规模计算
  • 水平扩展架构
  • 支持超大状态
  • 增量检查点机制
了解更多
性能卓越
  • 低延迟
  • 高吞吐
  • 内存计算
了解更多

最新博客列表 #

Apache Flink 1.16.2 Release Announcement
The Apache Flink Community is pleased to announce the second bug fix release of the Flink 1.16 series. This release includes 104 bug fixes, vulnerability fixes, and minor improvements for Flink 1.16. Below you will find a list of all bugfixes and improvements (excluding improvements to the build infrastructure and build stability). For a complete list of all changes see: JIRA. We highly recommend all users upgrade to Flink 1.16.2.

Apache Flink 1.17.1 Release Announcement
The Apache Flink Community is pleased to announce the first bug fix release of the Flink 1.17 series. This release includes 75 bug fixes, vulnerability fixes, and minor improvements for Flink 1.17. Below you will find a list of all bugfixes and improvements (excluding improvements to the build infrastructure and build stability). For a complete list of all changes see: JIRA. We highly recommend all users upgrade to Flink 1.17.1.

Apache Flink Kubernetes Operator 1.5.0 Release Announcement
The Apache Flink community is excited to announce the release of Flink Kubernetes Operator 1.5.0! The release focuses on improvements to the job autoscaler that was introduced in the previous release and general operational hardening of the operator. We encourage you to download the release and share your feedback with the community through the Flink mailing lists or JIRA! We hope you like the new release and we’d be eager to learn about your experience with it.