Package org.apache.hadoop.hbase.chaos.actions

Class RollingBatchSuspendResumeRsAction

java.lang.Object

org.apache.hadoop.hbase.chaos.actions.Action

org.apache.hadoop.hbase.chaos.actions.RollingBatchSuspendResumeRsAction

public class RollingBatchSuspendResumeRsAction
extends Action

Suspend then resume a ratio of the regionservers in a rolling fashion. At each step, either suspend a server, or resume one, sleeping (sleepTime) in between steps. The parameter maxSuspendedServers limits the maximum number of servers that can be down at the same time during rolling restarts.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static enum	RollingBatchSuspendResumeRsAction.SuspendOrResume

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.chaos.actions.Action

Action.ActionContext

Field Summary

Fields

Modifier and Type	Field	Description
private static final org.slf4j.Logger	LOG
private final int	maxSuspendedServers
private final float	ratio
private final long	sleepTime

Fields inherited from class org.apache.hadoop.hbase.chaos.actions.Action

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, monkeyProps, skipMetaRS, 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 Summary

Constructors

Constructor	Description
RollingBatchSuspendResumeRsAction(long sleepTime, float ratio)
RollingBatchSuspendResumeRsAction(long sleepTime, float ratio, int maxSuspendedServers)

Method Summary

Modifier and Type	Method	Description
protected org.slf4j.Logger	getLogger()	Retrieve the instance's Logger, for use throughout the class hierarchy.
void	perform()
protected List<org.apache.hadoop.hbase.ServerName>	selectServers()

Methods inherited from class org.apache.hadoop.hbase.chaos.actions.Action

forceBalancer, getConf, getCurrentServers, init, killDataNode, killJournalNode, killMaster, killNameNode, killRs, killZKNode, modifyAllTableColumns, modifyAllTableColumns, resumeRs, setBalancer, startDataNode, startJournalNode, startMaster, startNameNode, startRs, startZKNode, stopRs, suspendRs, unbalanceRegions

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

LOG

private static final org.slf4j.Logger LOG

ratio

private final float ratio

sleepTime

private final long sleepTime

maxSuspendedServers

private final int maxSuspendedServers

Constructor Details

RollingBatchSuspendResumeRsAction

public RollingBatchSuspendResumeRsAction(long sleepTime,
 float ratio)

RollingBatchSuspendResumeRsAction

public RollingBatchSuspendResumeRsAction(long sleepTime,
 float ratio,
 int maxSuspendedServers)

Method Details

getLogger

protected org.slf4j.Logger getLogger()

Description copied from class: Action

Retrieve the instance's Logger, for use throughout the class hierarchy.

Specified by:

getLogger in class Action

perform

public void perform()
             throws Exception

Overrides:

perform in class Action

Throws:

Exception

selectServers

protected List<org.apache.hadoop.hbase.ServerName> selectServers()
                                                          throws IOException

Throws:

IOException