Details
-
Task
-
Status: Resolved
-
Major
-
Resolution: Duplicate
-
None
-
None
-
None
-
None
Description
This section of code exists in the various schedulers in the method nodeUpdate():
// If the node is decommissioning, send an update to have the total // resource equal to the used resource, so no available resource to // schedule. // TODO: Fix possible race-condition when request comes in before // update is propagated if (nm.getState() == NodeState.DECOMMISSIONING) { this.rmContext .getDispatcher() .getEventHandler() .handle( new RMNodeResourceUpdateEvent(nm.getNodeID(), ResourceOption .newInstance(getSchedulerNode(nm.getNodeID()) .getAllocatedResource(), 0))); }
Investigate the TODO section.