Page History

public interface BlacklistStrategy {
    /**
     * Generate blacklisted items according to the abnormal task's location and cause.
     *
     * @param locations the abnormal tasks’ locations.
     * @param cause the cause of blacklisted items.
     * @param timestamp the create timestamp of blacklisted items.
     * @return the generated blacklisted items.
     */
    Collection<BlacklistedItem<?>> generateBlacklistedItems(
            Collection<TaskManagerLocation> locations, Throwable cause, long timestamp);
}

public interface BlacklistTracker {
    /**
     * Starts the blacklist tracker.
     */
    void start(ComponentMainThreadExecutor mainThreadExecutor);

    /**
     * Add new blacklisted items or update existing items.
     *
     * @param items The items to add or update
     * @return Newly added or updated items.
     */
    Collection<BlacklistedItem<?>> addNewBlacklistedItems(Collection<BlacklistedItem<?>> items);

    /**
     * Returns whether the given task manager is blacklisted.
     */
    boolean isBlacklistedTaskManager(ResourceID resourceID);

    /**
     * Get all blacklisted nodes.
     */
    Set<String> getBlacklistedNodes();

    /** Close the blacklist tracker. */
    void close();
}
     

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

public interface BlacklistedTaskManagerChecker {
    /**
     * Returns whether the given task manager is blacklisted.
     */
    boolean isBlacklistedTaskManager(ResourceID resourceID);
}


public interface SlotPoolService {

    /**
 Start the   * Start the encapsulated encapsulated slot pool implementation.
     */
    void start(
            JobMasterId jobMasterId,
            String address,
            ComponentMainThreadExecutor mainThreadExecutor,
            BlacklistedTaskManagerChecker blacklistedTaskManagerChecker)
            throws Exception;

   /**
     * Releases all slots belonging to the owning TaskExecutor if it has been registered.
     *
     * @param taskManagerId identifying the TaskExecutor
     * @param cause cause for failing the slots
     */
    void releaseSlotsOnTaskManager(ResourceID taskManagerId, Exception cause);

    /**
     * Releases all free slots belonging to the owning TaskExecutor if it has been registered.
     *
     * @param taskManagerId identifying the TaskExecutor
     * @param cause cause for failing the slots
     */
    void releaseFreeSlotsOnTaskManager(ResourceID taskManagerId, Exception cause);

    //...
}

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);

    // ...
}

public interface BlacklistedNodeRetriever {

    /**
     * Retrieve blacklisted nodes.
     */
    Set<String> getBlacklistedNodes();
}

public interface ResourceManagerDriver {

    /**
     * Initialize the deployment specific components.
     */
    void initialize(
            ResourceEventHandler<WorkerType> resourceEventHandler,
            ScheduledExecutor mainThreadExecutor,
            Executor ioExecutor,
            BlacklistedNodeRetriever blacklistedNodeRetriever)
            throws Exception;

    //...
}

public interface BlacklistListener {

    /**
     * Notify new blacklisted items.
     */
    void notifyNewBlacklistedItems(Collection<BlacklistedItem<?>> newItems);
}

public interface JobManagerGateway extends BlacklistListener {
    // ...
}

public interface ResourceManagerGateway extends BlacklistListener {     
    // ...
}   

public class TaskManagerLocation {

    public String getNodeId();
   
    // ...
}