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

所有流式场景

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

了解更多

正确性保证

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

了解更多

分层 API

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

了解更多

聚焦运维

灵活部署
高可用
保存点

了解更多

大规模计算

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

了解更多

性能卓越

低延迟
高吞吐
内存计算

了解更多

最新博客列表 #

Stateful Functions 3.3.0 Release Announcement
The Apache Flink community is excited to announce the release of Stateful Functions 3.3.0! Stateful Functions is a cross-platform stack for building Stateful Serverless applications, making it radically simpler to develop scalable, consistent, and elastic distributed applications. This new release upgrades the Flink runtime to 1.16.2. The binary distribution and source artifacts are now available on the updated Downloads page of the Flink website, and the most recent Java SDK, Python SDK,, GoLang SDK and JavaScript SDK distributions are available on Maven, PyPI, Github, and npm respectively.

Apache Flink Kubernetes Operator 1.6.0 Release Announcement
The Apache Flink community is excited to announce the release of Flink Kubernetes Operator 1.6.0! The release features a large number of improvements all across 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. Highlights # Improved and simplified rollback mechanism # Previously the rollback mechanism had some serious limitations always requiring the presence of HA metadata.

Announcing three new Apache Flink connectors, the new connector versioning strategy and externalization
New connectors # We’re excited to announce that Apache Flink now supports three new connectors: Amazon DynamoDB, MongoDB and OpenSearch! The connectors are available for both the DataStream and Table/SQL APIs. Amazon DynamoDB - This connector includes a sink that provides at-least-once delivery guarantees. MongoDB connector - This connector includes a source and sink that provide at-least-once guarantees. OpenSearch sink - This connector includes a sink that provides at-least-once guarantees.