Skip to content

N
nodemanager
Commit c916de2a authored by vicotor's avatar vicotor
Browse files
Options

update

parent 401d6169
Show whitespace changes
Inline Side-by-side
Showing with 3 additions and 3 deletions
server/workerManager.go
View file @ c916de2a
...@@ -576,9 +576,9 @@ func (wm *WorkerManager) handleWorkerMsg(worker *Worker) { ...@@ -576,9 +576,9 @@ func (wm *WorkerManager) handleWorkerMsg(worker *Worker) {
"worker-addr": worker.workerAddr, "worker-addr": worker.workerAddr,
}).Infof("receive worker resource map:%v", msg.ResourceMap) }).Infof("receive worker resource map:%v", msg.ResourceMap)
if !worker.registed { //if !worker.registed {
continue // continue
} //}
worker.info.resourceInfo = msg.ResourceMap worker.info.resourceInfo = msg.ResourceMap
wm.UpdateWorkerResourceInfo(worker, msg.ResourceMap.ResourceMap) wm.UpdateWorkerResourceInfo(worker, msg.ResourceMap.ResourceMap)
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment