分布式作业系统 Elastic-Job-Cloud 源码分析 —— 作业调度(一)
本文基于 Elastic-Job V2.1.5 版本分享
- 1. 概述
- 2. 作业执行类型
- 3. Producer 发布任务
- 3.1 常驻作业
- 3.2 瞬时作业
- 3.2.1 TransientProducerScheduler
- 3.2.2 注册瞬时作业
- 3.2.3 ProducerJob
- 3.3 小结
- 4. TaskLaunchScheduledService 提交任务
- 4.1 创建 Fenzo 任务请求
- 4.2 AppConstraintEvaluator
- 4.3 将任务请求分配到 Mesos Offer
- 4.4 创建 Mesos 任务信息
- 4.5 将任务运行时上下文放入运行时队列
- 4.6 从队列中删除已运行的作业
- 4.7 提交任务给 Mesos
- 5. TaskExecutor 执行任务
- 5.1 TaskThread
- 5.2 DaemonTaskScheduler
- 6. SchedulerEngine 处理任务的状态变更
- 666. 彩蛋
来源: https://juejin.im/entry/5a207fd16fb9a044fd118ce9