1

我是 Mesos 的新手,并试图了解任务成功完成时的流程以及如何使用 Chronos 将其更新到 Mesos。

(在 2.4.0 版中)当我有一个任务完成异步运行并成功完成的工作时,我的应用程序会将结果发送到“/scheduler/task/{id}”(在 Chronos TaskManagementResource.scala 中),然后它增加作业成功计数器,并更新作业的最后成功运行时间。然后它调用 jobsObserver.apply(JobFinished(job, taskStatus, attempt)) 我有点困惑。工作观察者做什么?

https://github.com/mesos/chronos/blob/c1348ddfd80eb8f888418805005066c230fc6ad2/src/main/scala/org/apache/mesos/chronos/scheduler/jobs/JobScheduler.scala#L216

https://github.com/apache/mesos/blob/c28fd3a93e0d9d9a868aec2380abd1dd338304ef/src/java/src/org/apache/mesos/Scheduler.java#L131

4

0 回答 0