Page History

...

BlacklistContext is the component responsible for performing blacklist actions on SlotPool, the details will be described in SlotPool.

public interface BlacklistContext {
    /** Perform the newly added or updated blacklist items on resources. */
    void blacklistResources(Collection<BlacklistedItem<?>> newlyAddedOrUpdatedItems);
}
   

...

1. When starting SlotManager, the BlacklistedTaskManagerChecker will be passed in to check whether a registered task manager is blacklisted.
2. When trying to fulfill the slot requirements by registered task managers, the blacklisted ones will be filtered out.
3. SlotManager will request new task managers from external resource managers if the registered resources cannot fulfill the requirements. The blacklist also takes effect when requesting new task managers, the details will be described in ResourceManagerDriver.

public interface SlotManager {

    /** Starts the slot manager with the given leader id and resource manager actions. */
    void start(
            ResourceManagerId newResourceManagerId,
            Executor newMainThreadExecutor,
            ResourceActions newResourceActions,
            BlacklistedTaskManagerChecker newBlacklistedTaskManagerChecker);

    //...
}

...