private void handleFailedSlotRequest ( SlotID slotId , AllocationID allocationId , Throwable cause ) { PendingSlotRequest pendingSlotRequest = pendingSlotRequests . get ( allocationId ) ; LOG . debug ( "Slot request with allocation id {} failed for slot {}." , allocationId , slotId , cause ) ; if ( null != pendingSlotRequest ) { pendingSlotRequest . setRequestFuture ( null ) ; try { internalRequestSlot ( pendingSlotRequest ) ; } catch ( ResourceManagerException e ) { pendingSlotRequests . remove ( allocationId ) ; resourceActions . notifyAllocationFailure ( pendingSlotRequest . getJobId ( ) , allocationId , e ) ; } } else { LOG . debug ( "There was not pending slot request with allocation id {}. Probably the request has been fulfilled or cancelled." , allocationId ) ; } }
Handles a failed slot request . The slot manager tries to find a new slot fulfilling the resource requirements for the failed slot request .