From 1a2ef4af038ed7e3f22947f8698bf231737cd678 Mon Sep 17 00:00:00 2001 From: Newnius Date: Mon, 22 Jun 2020 20:56:21 +0800 Subject: [PATCH] update --- src/job_manager.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/job_manager.go b/src/job_manager.go index 87e8602..1031ae3 100644 --- a/src/job_manager.go +++ b/src/job_manager.go @@ -143,8 +143,6 @@ func (jm *JobManager) start() { stats = append(stats, jm.stats[i]) } } - log.Info(jm.stats) - log.Info(stats) InstanceOfOptimizer().feedStats(jm.job, "PS", stats) stats = [][]TaskStatus{} for i, task := range jm.job.Tasks { @@ -152,6 +150,8 @@ func (jm *JobManager) start() { stats = append(stats, jm.stats[i]) } } + log.Info(jm.stats) + log.Info(stats) InstanceOfOptimizer().feedStats(jm.job, "Worker", stats) jm.returnResource(jm.status().Status) log.Info("JobMaster exited ", jm.job.Name)