流批一体 SQL
同一套 SQL 逻辑既能处理实时流数据，也能处理历史批数据，无需为实时与离线维护两套代码，大幅降低开发与维护成本。
产品概述
实时计算 Flink 版是全托管的 Apache Flink 服务，提供流式数据处理、流批一体计算与 CDC 数据同步能力。Flink 版免去了集群搭建、状态管理、容错恢复与调优的复杂度，支持 SQL 与 DataStream 两种开发方式，是构建实时数据管道与实时数仓的标准引擎。
全托管：免去 Flink 集群部署、状态后端配置与容错调优
流批一体：同一套 SQL 同时处理实时流与历史批数据，逻辑统一
CDC 同步：内置 MySQL、Oracle、PostgreSQL 等数据库变更捕获能力
Exactly-Once：端到端精确一次语义，保证数据不重不漏
生态完整：支持 30+ 上下游连接器，与 Hologres、MaxCompute 深度集成
最适合谁
需要实时数据处理能力的业务：实时数仓、实时风控、实时推荐、数据库实时同步。相比自建 Flink 集群，托管版免去了运维与调优负担，上线更快。
规格速查
以下参数用于快速比对本产品的核心能力边界。
| 开发方式 | SQL、DataStream API（Java/Scala）、Python API |
|---|---|
| 语义 | Exactly-Once、At-Least-Once |
| 状态管理 | 内置状态后端，支持大状态与增量 Checkpoint |
| 连接器 | Kafka、MySQL、Hologres、MaxCompute、OSS、SLS、Redis 等 30+ |
| CDC | MySQL、Oracle、PostgreSQL、SQL Server、MongoDB |
| 弹性 | 按 CU 弹性扩缩容，支持自动调优 |
| 运维 | 内置作业管理、监控告警、日志与指标 |
| 集成 | 与 DataWorks、Hologres、MaxCompute、ADB 集成 |
价格与计费
价格为整理时的参考区间，实际以下单页面为准。计费模式：包年包月（预购 CU） · 按量付费 · 免费试用额度。
| 套餐 / 规格 | 配置说明 | 参考价格 | 备注 |
|---|---|---|---|
| 按量付费 | 按 CU 时长 | 按量 元/CU/小时 | 弹性业务 |
| 包年包月 | 预购 CU | 低至 6 折 | 稳定作业 |
| 免费试用 | 新用户额度 | 0 | 含免费 CU 时长 |
| 自动调优 | 智能资源优化 | 按量 | 降低资源浪费 |
省钱提示：长期稳定负载优先包年包月并叠加节省计划；无状态批处理可用抢占式实例，成本可低至按量价的 10%。 查看成本优化指南 →
适用场景
实时数据管道与 ETL 数据库 CDC 实时同步 实时数仓数据接入 实时风控与告警 实时指标计算 日志实时处理 流批一体数据加工
功能拆解
CDC 数据同步
内置数据库变更数据捕获能力，可直接从 MySQL、Oracle 等数据库订阅 binlog 并同步到下游。配合 CTAS/CDAS 语法，一条 SQL 即可完成整库同步。
Exactly-Once 语义
配合 Checkpoint 与两阶段提交，保证端到端的精确一次处理，即使作业重启或故障恢复也不会重复或丢失数据，满足金融级数据准确性要求。
大状态管理
支持 TB 级状态存储与增量 Checkpoint，配合 RocksDB 状态后端，可支撑长时间窗口聚合与复杂事件处理场景。
自动调优
智能诊断作业瓶颈并给出资源配置建议，也可开启自动调优让系统动态调整并行度与资源，减少人工调参工作量。
丰富的连接器
内置 30+ 上下游连接器，覆盖消息队列、数据库、数据仓库、对象存储与日志服务，无需自行开发适配代码。
常见问题
Flink SQL 和 DataStream 怎么选？
SQL 开发效率高、易维护，覆盖 80% 以上的实时计算场景，推荐优先使用；当需要复杂自定义逻辑、自定义状态管理或精细控制时使用 DataStream API。
怎么同步 MySQL 到数仓？
使用 Flink CDC 连接器，通过 CDAS 语法一条语句即可完成整库同步。支持全量 + 增量自动切换，无需停机，是当前最推荐的数据库同步方案。
资源怎么规划？
按作业的吞吐量与状态大小估算 CU 数量。建议先用按量付费观察实际资源消耗，稳定后再评估包年包月；也可开启自动调优让系统动态调整。
相关产品
免费试用
实时数仓 Hologres
一体化实时数仓，写入即可查、高并发低延迟
- 一体化：实时写入、点查、OLAP 分析在同一系统完成，无需多套组件拼装
- 写入即查：数据写入后立即可查，无需等待批处理，延迟秒级
大数据
查看详情
免费试用
云原生大数据计算服务 MaxCompute
EB 级离线数据仓库，PB 级数据分钟级处理
- Serverless：无需管理集群，按实际计算量与存储量付费
- EB 级规模：单集群支持 EB 级存储与十万级并发作业
大数据
查看详情
免费试用
云消息队列 Kafka 版
高吞吐数据管道，日志与流处理的标准入口
- 全兼容开源：兼容 Apache Kafka 协议，现有客户端与工具直接可用
- 高吞吐：单实例可达百万级 TPS，适合大规模日志与数据管道
中间件
查看详情
免费试用
大数据开发治理平台 DataWorks
数据开发与治理中枢，让数据链路可管可控
- 一体化开发：数据集成、开发、调度、运维在统一界面完成
- 任务调度：支持分钟级调度、复杂依赖、跨周期依赖与补数据
大数据
查看详情