From d4593a7d3813a50c55aab6a84f6b89af255d6249 Mon Sep 17 00:00:00 2001 From: Newnius Date: Wed, 1 Jul 2020 16:59:39 +0800 Subject: [PATCH] update --- src/optimizer.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/src/optimizer.go b/src/optimizer.go index 9552c17..b619ce2 100644 --- a/src/optimizer.go +++ b/src/optimizer.go @@ -34,7 +34,7 @@ func (optimizer *Optimizer) Init(conf Configuration) { } func (optimizer *Optimizer) FeedTime(job Job, stats [][]TaskStatus) { - log.Info("optimizer feedTime", job) + //log.Info("optimizer feedTime", job) if len(stats) == 0 || len(job.Tasks) != 1 { return } @@ -237,13 +237,13 @@ func (optimizer *Optimizer) PredictTime(job Job) OptimizerJobExecutionTime { if err == nil && msg.Code == 0 { tmp := msg.Labels if v, ok := tmp["pre"]; ok { - res.Pre = int(math.Ceil(v / 100)) + res.Pre = int(math.Ceil(v)) } if v, ok := tmp["post"]; ok { - res.Post = int(math.Ceil(v/1024)) * 1024 + res.Post = int(math.Ceil(v)) } if v, ok := tmp["total"]; ok { - res.Total = int(math.Ceil(v)/10) * 10 + res.Total = int(math.Ceil(v)) } } return res