public void start ( ResourceManagerId newResourceManagerId , Executor newMainThreadExecutor , ResourceActions newResourceActions ) { LOG . info ( "Starting the SlotManager." ) ; this . resourceManagerId = Preconditions . checkNotNull ( newResourceManagerId ) ; mainThreadExecutor = Preconditions . checkNotNull ( newMainThreadExecutor ) ; resourceActions = Preconditions . checkNotNull ( newResourceActions ) ; started = true ; taskManagerTimeoutCheck = scheduledExecutor . scheduleWithFixedDelay ( ( ) -> mainThreadExecutor . execute ( ( ) -> checkTaskManagerTimeouts ( ) ) , 0L , taskManagerTimeout . toMilliseconds ( ) , TimeUnit . MILLISECONDS ) ; slotRequestTimeoutCheck = scheduledExecutor . scheduleWithFixedDelay ( ( ) -> mainThreadExecutor . execute ( ( ) -> checkSlotRequestTimeouts ( ) ) , 0L , slotRequestTimeout . toMilliseconds ( ) , TimeUnit . MILLISECONDS ) ; }
Starts the slot manager with the given leader id and resource manager actions .