Flink 任务调度与资源管理：从 JobGraph 到 ExecutionGraph 的完整旅程

渣渣盟

发布于 2026-11-01 15:05:47

1110

概述

作业提交后迟迟不 RUNNING，日志停在 “Waiting for slots”；或者 TaskManager 故障后整个作业全量重启、恢复时间远超预期——这些问题的根源往往不在业务代码，而在 JobGraph 到 ExecutionGraph 的翻译、Slot 的分配策略、以及故障恢复的真实边界。这篇文章沿着“图构建 → 调度模式 → Slot 分配 → 故障恢复”的主线拆解每一步的决策机制，

文章被收录于专栏：大数据技术大数据技术

原创声明：本文系作者授权腾讯云开发者社区发表，未经许可，不得转载。

如有侵权，请联系 cloudcommunity@tencent.com 删除。

flink