public class RollingBatchRestartRsAction extends BatchRestartRsAction
Modifier and Type | Class and Description |
---|---|
(package private) static class |
RollingBatchRestartRsAction.KillOrStart |
Action.ActionContext
Modifier and Type | Field and Description |
---|---|
private static org.slf4j.Logger |
LOG |
protected int |
maxDeadServers |
ratio
sleepTime
cluster, context, initialServers, initialStatus, KILL_DATANODE_TIMEOUT_DEFAULT, KILL_DATANODE_TIMEOUT_KEY, KILL_MASTER_TIMEOUT_DEFAULT, KILL_MASTER_TIMEOUT_KEY, KILL_NAMENODE_TIMEOUT_DEFAULT, KILL_NAMENODE_TIMEOUT_KEY, KILL_RS_TIMEOUT_DEFAULT, KILL_RS_TIMEOUT_KEY, KILL_ZK_NODE_TIMEOUT_DEFAULT, KILL_ZK_NODE_TIMEOUT_KEY, killDataNodeTimeout, killMasterTimeout, killNameNodeTimeout, killRsTimeout, killZkNodeTimeout, START_DATANODE_TIMEOUT_DEFAULT, START_DATANODE_TIMEOUT_KEY, START_MASTER_TIMEOUT_DEFAULT, START_MASTER_TIMEOUT_KEY, START_NAMENODE_TIMEOUT_DEFAULT, START_NAMENODE_TIMEOUT_KEY, START_RS_TIMEOUT_DEFAULT, START_RS_TIMEOUT_KEY, START_ZK_NODE_TIMEOUT_DEFAULT, START_ZK_NODE_TIMEOUT_KEY, startDataNodeTimeout, startMasterTimeout, startNameNodeTimeout, startRsTimeout, startZkNodeTimeout
Constructor and Description |
---|
RollingBatchRestartRsAction(long sleepTime,
float ratio) |
RollingBatchRestartRsAction(long sleepTime,
float ratio,
int maxDeadServers) |
Modifier and Type | Method and Description |
---|---|
static void |
main(String[] args)
Small test to ensure the class basically works.
|
void |
perform() |
protected List<org.apache.hadoop.hbase.ServerName> |
selectServers() |
gracefulRestartRs, restartDataNode, restartMaster, restartNameNode, restartRs, restartZKNode, sleep
forceBalancer, getConf, getCurrentServers, init, killDataNode, killMaster, killNameNode, killRs, killZKNode, modifyAllTableColumns, modifyAllTableColumns, resumeRs, setBalancer, startDataNode, startMaster, startNameNode, startRs, startZKNode, stopRs, suspendRs, unbalanceRegions
private static final org.slf4j.Logger LOG
protected int maxDeadServers
public RollingBatchRestartRsAction(long sleepTime, float ratio)
public RollingBatchRestartRsAction(long sleepTime, float ratio, int maxDeadServers)
public void perform() throws Exception
perform
in class BatchRestartRsAction
Exception
protected List<org.apache.hadoop.hbase.ServerName> selectServers() throws IOException
IOException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.