dolphinscheduler的ProcessDefinition流程分析

井礼骞
2023-12-01
projects/projectCode/process-definition
/projects/6034950904640/executors/start-process-instance
commandType == 其他
commandType == CommandType.COMPLEMENT_DATA
串行
并行
MasterSchedulerService 根据id%master节点个数
EventExecuteService
Y
N
定义流程
数据库生成taskDefinition,taskRelation以及processDefinition
执行流程
手动执行
定时执行
生成command
并行度/ 开始和结束之间总共次数 选择最小值 作为command的个数+依赖的schedules个数的command
生成自己本身/再生成依赖的schedules个数的command
生成scheduler
获取当前节点的commands
使用CountDownLatch闭锁逻辑将所有commands转换成processInstance
processInstance入库
初始化WorkflowExecuteThread 放入本地缓存
获取需要处理的事件
从缓存中获取
根据StateEventType进行不同的处理
根据告警设置处理告警星弟
运行模式
正常结束 意味着执行到了endprocess
开始
结束
 类似资料: