Flink 速查
共 24 条 Apache Flink 用法，涵盖基础与运行、DataStream / Table、时间与窗口、状态与容错、连接器与调优。 支持搜索与分类筛选，点击即可复制。
基础与运行
流批一体的计算引擎。
| 命令 | 说明 |
|---|---|
| 查看版本 | |
| 启动本地集群（含 JobManager/TaskManager） | |
| 提交作业 | |
| 列出 / 取消作业 | |
| 作业监控 |
DataStream / Table
两种主流 API。
| 命令 | 说明 |
|---|---|
| 流处理入口 | |
| 典型算子链（Java） | |
| 从集合创建流 | |
| Table API / SQL 入口 | |
| SQL 查询 |
时间与窗口
事件时间与水位线。
| 命令 | 说明 |
|---|---|
| 指定事件时间与水位线 | |
| 滚动窗口 | |
| 滑动 / 会话窗口 | |
| 迟到数据处理 |
状态与容错
有状态计算与检查点。
| 命令 | 说明 |
|---|---|
| 每秒级启用检查点（毫秒） | |
| 键控状态类型 | |
| 配置检查点存储 | |
| 保存点（升级作业用） | |
| 从保存点恢复 |
连接器与调优
常用数据源与并行度。
| 命令 | 说明 |
|---|---|
| 常用官方连接器 | |
| 设置并行度 | |
| 资源参数 | |
| 提交时指定并行度 | |
| 性能定位 |
使用说明
Flink 速查：基础与运行、DataStream / Table、时间与窗口、状态与容错、连接器与调优；支持搜索与分类筛选，点击即可复制。
- 按用途点分类：基础与运行、DataStream/Table、时间与窗口、状态与容错、连接器与调优。
- 点「命令」列复制到终端或代码。
- 有状态作业务必开 checkpoint，升级作业用 savepoint。
- 事件时间场景要配 Watermark，并处理迟到数据。
常见问题
- checkpoint 和 savepoint 区别？
- checkpoint 由系统自动、用于故障恢复（失败可丢弃）；savepoint 是手动触发的持久快照，用于升级/迁移作业，需保留。
- 怎么排查慢？
- 看 Web UI 的反压（Backpressure）与各算子指标，常见原因是数据倾斜、状态过大或并行度不足。
- 需要联网吗？
- 速查内容本地可用；下载发行版与依赖需联网。