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 and Description
(package private) static class	RollingBatchSuspendResumeRsAction.SuspendOrResume

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

Action.ActionContext

Field Summary

Fields

Modifier and Type	Field and Description
private static org.slf4j.Logger	LOG
private int	maxSuspendedServers
private float	ratio
private 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 and Description
RollingBatchSuspendResumeRsAction(long sleepTime, float ratio)
RollingBatchSuspendResumeRsAction(long sleepTime, float ratio, int maxSuspendedServers)

Method Summary

Modifier and Type	Method and 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, killMaster, killNameNode, killRs, killZKNode, modifyAllTableColumns, modifyAllTableColumns, resumeRs, setBalancer, startDataNode, 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 Detail

LOG

private static final org.slf4j.Logger LOG

ratio

private final float ratio

sleepTime

private final long sleepTime

maxSuspendedServers

private final int maxSuspendedServers

Constructor Detail

RollingBatchSuspendResumeRsAction

public RollingBatchSuspendResumeRsAction(long sleepTime,
                                         float ratio)

RollingBatchSuspendResumeRsAction

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

Method Detail

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