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

所有流式场景

事件驱动应用
流批分析
数据管道 & ETL

了解更多

正确性保证

Exactly-once 状态一致性
事件时间处理
成熟的迟到数据处理

了解更多

分层 API

SQL on Stream & Batch Data
DataStream API & DataSet API
ProcessFunction (Time & State)

了解更多

聚焦运维

灵活部署
高可用
保存点

了解更多

大规模计算

水平扩展架构
支持超大状态
增量检查点机制

了解更多

性能卓越

低延迟
高吞吐
内存计算

了解更多

最新博客列表 #

Apache Flink 1.16.1 Release Announcement
The Apache Flink Community is pleased to announce the first bug fix release of the Flink 1.16 series. This release includes 84 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.1.

Delegation Token Framework: Obtain, Distribute and Use Temporary Credentials Automatically
The Apache Flink Community is pleased to announce that the upcoming minor version of Flink (1.17) includes the Delegation Token Framework proposed in FLIP-272. This enables Flink to authenticate to external services at a central location (JobManager) and distribute authentication tokens to the TaskManagers. Introduction # Authentication in distributed systems is not an easy task. Previously all worker nodes (TaskManagers) reading from or writing to an external system needed to authenticate on their own.

Apache Flink Table Store 0.3.0 Release Announcement
The Apache Flink community is pleased to announce the release of the Apache Flink Table Store (0.3.0). We highly recommend all users upgrade to Flink Table Store 0.3.0. 0.3.0 completed 150+ issues, which were completed by nearly 30 contributors. Please check out the full documentation for detailed information and user guides. Flink Table Store 0.3 completes many exciting features, enhances its ability as a data lake storage and greatly improves the availability of its stream pipeline.