正确性保障
支持精确一次状态一致性、事件时间处理和复杂的迟到数据处理。
Apache Flink
Stateful Computations over Data StreamsApache Flink 是用于有界与无界数据流有状态计算的框架和分布式处理引擎,支持在常见集群环境中运行,以内存级速度处理不同规模的数据任务。
从一致性保障、分层 API 到部署运维与横向扩展,Apache Flink 覆盖流处理和批处理应用的关键环节。
支持精确一次状态一致性、事件时间处理和复杂的迟到数据处理。
提供面向流批数据的 SQL、DataStream API 和 ProcessFunction,覆盖时间与状态处理。
支持灵活部署、高可用配置,以及用于恢复的 savepoint。
采用横向扩展架构,支持超大状态和增量 checkpoint。
支持低延迟、高吞吐和内存计算,适用于实时数据处理任务。
查看 Flink Agents、原生 S3 文件系统和 Flink 2.3.0 等公开发布与技术动态。
Flink Agents 0.3 系列发布首个 bug 修复版本,包含 5 项 bug 修复、Flink 2.3 分发支持和安装器更新。
Apache Flink 原生 S3 文件系统面向性能和生产环境设计,用于读取和写入应用数据、物化流式 sink,以及存储 checkpoint 和 savepoint。
Flink 2.3.0 扩展了 SQL 能力,加入变更日志转换算子并增强物化表等功能。
从稳定版文档、长期支持版本到 Kubernetes Operator、CDC、ML 和 Stateful Functions 文档,选择对应资源开始使用。