开源工具 · 大数据运维
Apache Flink
串联源位点、事件时间、算子状态、checkpoint 与 sink 提交，定位 Flink 反压和恢复失败并验证端到端结果。
Overview
定位与架构
依据 Flink 1.20 的作业模型与 REST 接口；Flink 2.x、Operator 和各连接器需按对应版本复核。使用已有作业的只读状态采样，恢复演练使用隔离输入与输出。
运维重点
记录 Job ID、operator UID、并行度、状态后端、checkpoint 存储和连接器版本，准备具备 GET 权限的认证网关。curl 示例仅在当前终端设置指向受控 HTTPS 网关的 FLINK_REST_URL 与实际 JOB_ID；凭据使用环境已配置的认证方式。
使用边界
不直接取消生产作业、删除 checkpoint、强制跳过无法映射的状态或对生产 sink 重放。状态一致性与外部系统提交是不同层面的保证。
本站按 L1 资料收录，未提供在线体验；文档和参考图不代表已部署或经过环境验证。