| 类 | 说明 |
|---|---|
| ShutDownHook | |
| TaskCompensatorJob |
当worker进程执行完毕后(或worker进程crash),资源会被释放出来,此时应该针对正在运行中的任务来进行补偿,给它们分配更多的worker进程.
|
| TaskDeleteJob | |
| TaskStatusChecker | |
| TimeoutPartitionTaskChecker | |
| WorkerHealthChecker | |
| WorkerProcessorNumberCorrector |
Copyright © 2016. All rights reserved.