Commit efad1e48 authored by vicotor's avatar vicotor

update

parent 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