| ... | ... | @@ -27,11 +27,14 @@ Controller重启（对任务的操作） |
|
|
|
Controller新增接口和处理机制
|
|
|
|
----
|
|
|
|
|
|
|
|
- 【机制】Controller的engine管理模块，（1）收到stop-engine的调用时，或（2）发现分析引擎失联时（连续3次没有收到心跳update-engine-info），对映射表中所有隶属于该engine的每个task：
|
|
|
|
- 【机制】Controller的engine管理模块，收到stop-engine的调用时，对映射表中所有隶属于该engine的每个task：
|
|
|
|
- 重新分配engine，并调用task模块的restart接口，
|
|
|
|
- 从映射表中将该项删除
|
|
|
|
- 【机制】Controller的engine管理模块，发现分析引擎失联时（连续3次没有收到心跳update-engine-info），对映射表中所有隶属于该engine的每个task：
|
|
|
|
- 调用task模块的stop接口，向原分析引擎发送停止任务运行的请求
|
|
|
|
- 重新分配engine，并调用task模块的restart接口，
|
|
|
|
- 从映射表中将该项删除
|
|
|
|
- 【接口】Controller的engine管理模块，在处理update-task-status接口的调用时，对映射表的<taskId, engineId>项进行维护：对于新的进入运行状态的任务，添加到映射表中；对于进入其它状态的任务，则从映射表中删除
|
|
|
|
- 【机制】Controller的engine管理模块，在处理update-task-status接口的调用时，对映射表的<taskId, engineId>项进行维护：对于新的进入运行状态的任务，添加到映射表中；对于进入其它状态的任务，则从映射表中删除
|
|
|
|
- 【接口】Controller提供查询特定分析引擎上所有运行任务的接口
|
|
|
|
- 【接口】Controller对特定任务进行restart的接口
|
|
|
|
|
| ... | ... | |
