YAO/YAO-scheduler
1
0
Fork 0
mirror of https://github.com/newnius/YAO-scheduler.git synced 2025-12-13 07:46:43 +00:00
Code Issues Releases Wiki Activity

update

Browse Source
This commit is contained in:
Newnius
2020-06-26 13:12:04 +08:00
parent f17b594744
commit 2587186b6e
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/optimizer.go
View File

@@ -119,6 +119,7 @@ func (optimizer *Optimizer) feedStats(job Job, role string, stats [][]TaskStatus
exceptions["ps_hosts"] = true exceptions["ps_hosts"] = true
exceptions["worker_hosts"] = true exceptions["worker_hosts"] = true
exceptions["task_index"] = true exceptions["task_index"] = true
exceptions["job_name"] = true
pairs := strings.Split(cmd, " ") pairs := strings.Split(cmd, " ")
for _, pair := range pairs { for _, pair := range pairs {
@@ -165,7 +166,7 @@ func (optimizer *Optimizer) feedStats(job Job, role string, stats [][]TaskStatus
} }
optimizer.versions[jobName]++ optimizer.versions[jobName]++
if optimizer.versions[jobName]%5 == 0 { if optimizer.versions[jobName]%3 == 0 {
optimizer.train(jobName) optimizer.train(jobName)
} }
}() }()
@@ -438,6 +439,7 @@ func (optimizer *Optimizer) PredictReq(job Job, role string) MsgJobReq {
exceptions["ps_hosts"] = true exceptions["ps_hosts"] = true
exceptions["worker_hosts"] = true exceptions["worker_hosts"] = true
exceptions["task_index"] = true exceptions["task_index"] = true
exceptions["job_name"] = true
pairs := strings.Split(cmd, " ") pairs := strings.Split(cmd, " ")
for _, pair := range pairs { for _, pair := range pairs {