Apache Flink

Apache Flink

Stateful Computations over Data StreamsApache Flink 是用于有界与无界数据流有状态计算的框架和分布式处理引擎,支持在常见集群环境中运行,以内存级速度处理不同规模的数据任务。

Apache Flink 页面快照
2.3
Flink 当前稳定版本
1.20
Flink 长期支持版本
1.15
Kubernetes Operator 最新版本
3.6
Flink CDC 当前稳定版本
核心能力

面向实时数据处理的完整能力

从一致性保障、分层 API 到部署运维与横向扩展,Apache Flink 覆盖流处理和批处理应用的关键环节。

正确性保障

支持精确一次状态一致性、事件时间处理和复杂的迟到数据处理。

分层编程接口

提供面向流批数据的 SQL、DataStream API 和 ProcessFunction,覆盖时间与状态处理。

灵活运维部署

支持灵活部署、高可用配置,以及用于恢复的 savepoint。

大规模扩展

采用横向扩展架构,支持超大状态和增量 checkpoint。

低延迟处理

支持低延迟、高吞吐和内存计算,适用于实时数据处理任务。

最新动态

Flink 项目更新

查看 Flink Agents、原生 S3 文件系统和 Flink 2.3.0 等公开发布与技术动态。

Apache Flink Agents 0.3.1 发布公告

Flink Agents 0.3 系列发布首个 bug 修复版本,包含 5 项 bug 修复、Flink 2.3 分发支持和安装器更新。

推出原生 S3 文件系统

Apache Flink 原生 S3 文件系统面向性能和生产环境设计,用于读取和写入应用数据、物化流式 sink,以及存储 checkpoint 和 savepoint。

Apache Flink 2.3.0 发布公告

Flink 2.3.0 扩展了 SQL 能力,加入变更日志转换算子并增强物化表等功能。

官方资源

文档、版本与实践入口

从稳定版文档、长期支持版本到 Kubernetes Operator、CDC、ML 和 Stateful Functions 文档,选择对应资源开始使用。

Apache Flink

从这里开始使用Apache Flink。