public class NodesListManager extends org.apache.hadoop.service.CompositeService implements org.apache.hadoop.yarn.event.EventHandler<NodesListManagerEvent>
Modifier and Type | Class and Description |
---|---|
static class |
NodesListManager.CachedResolver |
static class |
NodesListManager.DirectResolver |
static interface |
NodesListManager.Resolver |
Constructor and Description |
---|
NodesListManager(RMContext rmContext) |
Modifier and Type | Method and Description |
---|---|
Set<org.apache.hadoop.yarn.api.records.NodeId> |
checkForDecommissioningNodes()
It checks for any nodes in decommissioning state
|
static org.apache.hadoop.yarn.api.records.NodeId |
createUnknownNodeId(String host)
A NodeId instance needed upon startup for populating inactive nodes Map.
|
org.apache.hadoop.util.HostsFileReader |
getHostsReader() |
int |
getNodeRemovalCheckInterval() |
NodesListManager.Resolver |
getResolver() |
void |
handle(NodesListManagerEvent event) |
boolean |
isUntrackedNode(String hostName) |
boolean |
isValidNode(String hostName) |
void |
refreshNodes(org.apache.hadoop.conf.Configuration yarnConf) |
void |
refreshNodesForcefully()
Forcefully decommission the nodes if they are in DECOMMISSIONING state
|
void |
refreshNodesGracefully(org.apache.hadoop.conf.Configuration conf)
Refresh the nodes gracefully
|
protected void |
serviceInit(org.apache.hadoop.conf.Configuration conf) |
void |
serviceStop() |
void |
setNodeRemovalCheckInterval(int interval) |
addIfService, addService, getServices, removeService, serviceStart
close, getBlockers, getConfig, getFailureCause, getFailureState, getLifecycleHistory, getName, getServiceState, getStartTime, init, isInState, noteFailure, putBlocker, registerGlobalListener, registerServiceListener, removeBlocker, setConfig, start, stop, toString, unregisterGlobalListener, unregisterServiceListener, waitForServiceToStop
public NodesListManager(RMContext rmContext)
protected void serviceInit(org.apache.hadoop.conf.Configuration conf) throws Exception
serviceInit
in class org.apache.hadoop.service.CompositeService
Exception
public void serviceStop()
serviceStop
in class org.apache.hadoop.service.CompositeService
public void refreshNodes(org.apache.hadoop.conf.Configuration yarnConf) throws IOException, org.apache.hadoop.yarn.exceptions.YarnException
IOException
org.apache.hadoop.yarn.exceptions.YarnException
public int getNodeRemovalCheckInterval()
public void setNodeRemovalCheckInterval(int interval)
public NodesListManager.Resolver getResolver()
public boolean isValidNode(String hostName)
public void handle(NodesListManagerEvent event)
handle
in interface org.apache.hadoop.yarn.event.EventHandler<NodesListManagerEvent>
public org.apache.hadoop.util.HostsFileReader getHostsReader()
public boolean isUntrackedNode(String hostName)
public void refreshNodesGracefully(org.apache.hadoop.conf.Configuration conf) throws IOException, org.apache.hadoop.yarn.exceptions.YarnException
conf
- IOException
org.apache.hadoop.yarn.exceptions.YarnException
public Set<org.apache.hadoop.yarn.api.records.NodeId> checkForDecommissioningNodes()
public void refreshNodesForcefully()
public static org.apache.hadoop.yarn.api.records.NodeId createUnknownNodeId(String host)
Copyright © 2017 Apache Software Foundation. All Rights Reserved.