flink

Apache Flink 流处理命令行

补充说明

flink CLI 提交和管理 Flink 作业，支持 JAR、Savepoint、Checkpoint 和 SQL Client。它适合有状态流处理和事件驱动应用。

常用示例

flink run -c com.example.Main app.jar
flink run -p 4 app.jar
flink list
flink list -r
flink cancel <job-id>
flink stop <job-id>
flink savepoint <job-id> /backups/savepoints
flink run -s /backups/savepoints/savepoint-xxx app.jar
sql-client.sh

作业与状态

概念	含义
JobManager	作业调度与协调
TaskManager	执行任务和状态
Checkpoint	周期性状态快照
Savepoint	手动触发的状态快照
Slot	TaskManager 的资源单位
State Backend	状态存储（内存/RocksDB）

易错点与排错

flink run 需要正确的 JobManager 地址和依赖 JAR。
并行度受 slot 数和资源限制；-p 不能超过可用 slot。
Checkpoint 失败会导致状态无法恢复；先看存储和超时。
Savepoint 要定期做，升级/迁移作业时依赖它。
状态后端和序列化器变更可能影响兼容性。
SQL Client 的 catalog/connector 配置与 JAR 作业不同。
版本升级要确认状态兼容和 API 变化。

flink

补充说明

常用示例

作业与状态

易错点与排错

相关命令