DolphinScheduler笔记之8: 状态
原文中文,约5300字,阅读约需13分钟。发表于: 。在工作流的生命周期里,初步介绍过工作流的各种状态。 1. 状态机 如果我们实现一个任务调度系统,首要是梳理清楚任务状态。 以 Flink 任务流程为例: 提交:任务提交后,资源调度需要分配资源、初始化Container、启动JobManager、TaskManager等。因此任务首先是从初始化到提交中,再从提交成功到运行,当然任务也有可能因为各种原因导致提交失败。...
本文介绍了工作流的状态机和DolphinScheduler的状态机,通过队列依次处理来确保顺序性。TaskEventService负责任务状态的变化,TaskEventHandler处理每种类型的事件。任务状态处理后,发送了触发工作流状态变化的事件。