Ying’s Blog
·
DolphinScheduler笔记之8: 状态
💡
原文中文，约5300字，阅读约需13分钟。
📝
内容提要
本文介绍了工作流的状态机和DolphinScheduler的状态机，通过队列依次处理来确保顺序性。TaskEventService负责任务状态的变化，TaskEventHandler处理每种类型的事件。任务状态处理后，发送了触发工作流状态变化的事件。
🎯
关键要点
- 工作流的生命周期中，任务状态包括初始化、提交中、运行、成功、失败、已停止。
- 状态机是任务调度系统的核心概念，通过事件触发状态变化。
- 为了确保任务状态的顺序性，事件应在单线程中处理。
- DolphinScheduler的工作流由多个任务组成，任务状态与工作流状态不同。
- DolphinScheduler通过队列依次处理事件以确保顺序性。
- TaskEventService负责任务状态的变化，处理任务事件的分发和处理。
- Worker完成任务后发送TASK_EXECUTE_RESULT事件回master。
- TaskEventHandler处理任务事件，确保任务状态的正确性。
- 任务状态处理后，发送触发工作流状态变化的事件。
🏷️
标签
➡️
