public void suspend ( ) { LOG . info ( "Suspending the SlotManager." ) ; // stop the timeout checks for the TaskManagers and the SlotRequests if ( taskManagerTimeoutCheck != null ) { taskManagerTimeoutCheck . cancel ( false ) ; taskManagerTimeoutCheck = null ; } if ( slotRequestTimeoutCheck != null ) { slotRequestTimeoutCheck . cancel ( false ) ; slotRequestTimeoutCheck = null ; } for ( PendingSlotRequest pendingSlotRequest : pendingSlotRequests . values ( ) ) { cancelPendingSlotRequest ( pendingSlotRequest ) ; } pendingSlotRequests . clear ( ) ; ArrayList < InstanceID > registeredTaskManagers = new ArrayList <> ( taskManagerRegistrations . keySet ( ) ) ; for ( InstanceID registeredTaskManager : registeredTaskManagers ) { unregisterTaskManager ( registeredTaskManager ) ; } resourceManagerId = null ; resourceActions = null ; started = false ; }
Suspends the component . This clears the internal state of the slot manager .