public class RasBlacklistStrategy extends DefaultBlacklistStrategy
Blacklisting strategy just like the default one, but specifically setup for use with the resource aware scheduler.
DEFAULT_BLACKLIST_SCHEDULER_RESUME_TIME, DEFAULT_BLACKLIST_SCHEDULER_TOLERANCE_COUNT| Constructor and Description |
|---|
RasBlacklistStrategy() |
| Modifier and Type | Method and Description |
|---|---|
protected Set<String> |
releaseBlacklistWhenNeeded(Cluster cluster,
List<String> blacklistedNodeIds)
Decide when/if to release blacklisted hosts.
|
createHostToSupervisorMap, getBlacklist, prepare, resumeFromBlacklistprotected Set<String> releaseBlacklistWhenNeeded(Cluster cluster, List<String> blacklistedNodeIds)
DefaultBlacklistStrategyDecide when/if to release blacklisted hosts.
releaseBlacklistWhenNeeded in class DefaultBlacklistStrategycluster - the current state of the cluster.blacklistedNodeIds - the current set of blacklisted node ids sorted by earliestCopyright © 2021 The Apache Software Foundation. All rights reserved.