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

Class Action

java.lang.Object

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

Direct Known Subclasses:

AddColumnAction, ChangeBloomFilterAction, ChangeCompressionAction, ChangeEncodingAction, ChangeSplitPolicyAction, ChangeVersionsAction, CompactMobAction, CompactRandomRegionOfTableAction, CompactTableAction, CorruptDataFilesAction, DecreaseMaxHFileSizeAction, DeleteDataFilesAction, DumpClusterStatusAction, DumpHdfsClusterStatusAction, FlushRandomRegionOfTableAction, FlushTableAction, ForceBalancerAction, MergeRandomAdjacentRegionsOfTableAction, MoveRandomRegionOfTableAction, MoveRegionsOfTableAction, RemoveColumnAction, RestartActionBaseAction, RollingBatchSuspendResumeRsAction, SnapshotTableAction, SplitAllRegionOfTableAction, SplitRandomRegionOfTableAction, SudoCommandAction, TruncateTableAction, UnbalanceKillAndRebalanceAction, UnbalanceRegionsAction

public abstract class Action
extends Object

A (possibly mischievous) action that the ChaosMonkey can perform.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	Action.ActionContext	Context for Action's

Field Summary

Fields

Modifier and Type	Field	Description
protected HBaseCluster	cluster
protected Action.ActionContext	context
protected org.apache.hadoop.hbase.ServerName[]	initialServers
protected org.apache.hadoop.hbase.ClusterMetrics	initialStatus
protected static final long	KILL_DATANODE_TIMEOUT_DEFAULT
static final String	KILL_DATANODE_TIMEOUT_KEY
protected static final long	KILL_MASTER_TIMEOUT_DEFAULT
static final String	KILL_MASTER_TIMEOUT_KEY
protected static final long	KILL_NAMENODE_TIMEOUT_DEFAULT
static final String	KILL_NAMENODE_TIMEOUT_KEY
protected static final long	KILL_RS_TIMEOUT_DEFAULT
static final String	KILL_RS_TIMEOUT_KEY
protected static final long	KILL_ZK_NODE_TIMEOUT_DEFAULT
static final String	KILL_ZK_NODE_TIMEOUT_KEY
protected long	killDataNodeTimeout
protected long	killMasterTimeout
protected long	killNameNodeTimeout
protected long	killRsTimeout
protected long	killZkNodeTimeout
protected Properties	monkeyProps
protected boolean	skipMetaRS
protected static final long	START_DATANODE_TIMEOUT_DEFAULT
static final String	START_DATANODE_TIMEOUT_KEY
protected static final long	START_MASTER_TIMEOUT_DEFAULT
static final String	START_MASTER_TIMEOUT_KEY
protected static final long	START_NAMENODE_TIMEOUT_DEFAULT
static final String	START_NAMENODE_TIMEOUT_KEY
protected static final long	START_RS_TIMEOUT_DEFAULT
static final String	START_RS_TIMEOUT_KEY
protected static final long	START_ZK_NODE_TIMEOUT_DEFAULT
static final String	START_ZK_NODE_TIMEOUT_KEY
protected long	startDataNodeTimeout
protected long	startMasterTimeout
protected long	startNameNodeTimeout
protected long	startRsTimeout
protected long	startZkNodeTimeout

Constructor Summary

Constructors

Constructor	Description
Action()

Method Summary

Modifier and Type	Method	Description
protected void	forceBalancer()
org.apache.hadoop.conf.Configuration	getConf()
protected org.apache.hadoop.hbase.ServerName[]	getCurrentServers()	Returns current region servers - active master
protected abstract org.slf4j.Logger	getLogger()	Retrieve the instance's Logger, for use throughout the class hierarchy.
void	init(Action.ActionContext context)
protected void	killDataNode(org.apache.hadoop.hbase.ServerName server)
protected void	killJournalNode(org.apache.hadoop.hbase.ServerName server)
protected void	killMaster(org.apache.hadoop.hbase.ServerName server)
protected void	killNameNode(org.apache.hadoop.hbase.ServerName server)
protected void	killRs(org.apache.hadoop.hbase.ServerName server)
protected void	killZKNode(org.apache.hadoop.hbase.ServerName server)
protected void	modifyAllTableColumns(org.apache.hadoop.hbase.TableName tableName, BiConsumer<String,org.apache.hadoop.hbase.client.ColumnFamilyDescriptorBuilder> transform)	Apply a transform to all columns in a given table.
protected void	modifyAllTableColumns(org.apache.hadoop.hbase.TableName tableName, Consumer<org.apache.hadoop.hbase.client.ColumnFamilyDescriptorBuilder> transform)	Apply a transform to all columns in a given table.
void	perform()
protected void	resumeRs(org.apache.hadoop.hbase.ServerName server)
protected void	setBalancer(boolean onOrOff, boolean synchronous)
protected void	startDataNode(org.apache.hadoop.hbase.ServerName server)
protected void	startJournalNode(org.apache.hadoop.hbase.ServerName server)
protected void	startMaster(org.apache.hadoop.hbase.ServerName server)
protected void	startNameNode(org.apache.hadoop.hbase.ServerName server)
protected void	startRs(org.apache.hadoop.hbase.ServerName server)
protected void	startZKNode(org.apache.hadoop.hbase.ServerName server)
protected void	stopRs(org.apache.hadoop.hbase.ServerName server)
protected void	suspendRs(org.apache.hadoop.hbase.ServerName server)
protected void	unbalanceRegions(org.apache.hadoop.hbase.ClusterMetrics clusterStatus, List<org.apache.hadoop.hbase.ServerName> fromServers, List<org.apache.hadoop.hbase.ServerName> toServers, double fractionOfRegions)

Methods inherited from class java.lang.Object

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

Field Details

KILL_MASTER_TIMEOUT_KEY

public static final String KILL_MASTER_TIMEOUT_KEY

See Also:

• Constant Field Values

START_MASTER_TIMEOUT_KEY

public static final String START_MASTER_TIMEOUT_KEY

See Also:

• Constant Field Values

KILL_RS_TIMEOUT_KEY

public static final String KILL_RS_TIMEOUT_KEY

See Also:

• Constant Field Values

START_RS_TIMEOUT_KEY

public static final String START_RS_TIMEOUT_KEY

See Also:

• Constant Field Values

KILL_ZK_NODE_TIMEOUT_KEY

public static final String KILL_ZK_NODE_TIMEOUT_KEY

See Also:

• Constant Field Values

START_ZK_NODE_TIMEOUT_KEY

public static final String START_ZK_NODE_TIMEOUT_KEY

See Also:

• Constant Field Values

KILL_DATANODE_TIMEOUT_KEY

public static final String KILL_DATANODE_TIMEOUT_KEY

See Also:

• Constant Field Values

START_DATANODE_TIMEOUT_KEY

public static final String START_DATANODE_TIMEOUT_KEY

See Also:

• Constant Field Values

KILL_NAMENODE_TIMEOUT_KEY

public static final String KILL_NAMENODE_TIMEOUT_KEY

See Also:

• Constant Field Values

START_NAMENODE_TIMEOUT_KEY

public static final String START_NAMENODE_TIMEOUT_KEY

See Also:

• Constant Field Values

KILL_MASTER_TIMEOUT_DEFAULT

protected static final long KILL_MASTER_TIMEOUT_DEFAULT

See Also:

• Constant Field Values

START_MASTER_TIMEOUT_DEFAULT

protected static final long START_MASTER_TIMEOUT_DEFAULT

See Also:

• Constant Field Values

KILL_RS_TIMEOUT_DEFAULT

protected static final long KILL_RS_TIMEOUT_DEFAULT

See Also:

• Constant Field Values

START_RS_TIMEOUT_DEFAULT

protected static final long START_RS_TIMEOUT_DEFAULT

See Also:

• Constant Field Values

KILL_ZK_NODE_TIMEOUT_DEFAULT

protected static final long KILL_ZK_NODE_TIMEOUT_DEFAULT

See Also:

• Constant Field Values

START_ZK_NODE_TIMEOUT_DEFAULT

protected static final long START_ZK_NODE_TIMEOUT_DEFAULT

See Also:

• Constant Field Values

KILL_DATANODE_TIMEOUT_DEFAULT

protected static final long KILL_DATANODE_TIMEOUT_DEFAULT

See Also:

• Constant Field Values

START_DATANODE_TIMEOUT_DEFAULT

protected static final long START_DATANODE_TIMEOUT_DEFAULT

See Also:

• Constant Field Values

KILL_NAMENODE_TIMEOUT_DEFAULT

protected static final long KILL_NAMENODE_TIMEOUT_DEFAULT

See Also:

• Constant Field Values

START_NAMENODE_TIMEOUT_DEFAULT

protected static final long START_NAMENODE_TIMEOUT_DEFAULT

See Also:

• Constant Field Values

context

protected Action.ActionContext context

cluster

protected HBaseCluster cluster

initialStatus

protected org.apache.hadoop.hbase.ClusterMetrics initialStatus

initialServers

protected org.apache.hadoop.hbase.ServerName[] initialServers

monkeyProps

protected Properties monkeyProps

killMasterTimeout

protected long killMasterTimeout

startMasterTimeout

protected long startMasterTimeout

killRsTimeout

protected long killRsTimeout

startRsTimeout

protected long startRsTimeout

killZkNodeTimeout

protected long killZkNodeTimeout

startZkNodeTimeout

protected long startZkNodeTimeout

killDataNodeTimeout

protected long killDataNodeTimeout

startDataNodeTimeout

protected long startDataNodeTimeout

killNameNodeTimeout

protected long killNameNodeTimeout

startNameNodeTimeout

protected long startNameNodeTimeout

skipMetaRS

protected boolean skipMetaRS

Constructor Details

Action

public Action()

Method Details

getLogger

protected abstract org.slf4j.Logger getLogger()

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

init

public void init(Action.ActionContext context)
          throws IOException

Throws:

IOException

perform

public void perform()
             throws Exception

Throws:

Exception

getCurrentServers

protected org.apache.hadoop.hbase.ServerName[] getCurrentServers()
                                                          throws IOException

Returns current region servers - active master

Throws:

IOException

killMaster

protected void killMaster(org.apache.hadoop.hbase.ServerName server)
                   throws IOException

Throws:

IOException

startMaster

protected void startMaster(org.apache.hadoop.hbase.ServerName server)
                    throws IOException

Throws:

IOException

stopRs

protected void stopRs(org.apache.hadoop.hbase.ServerName server)
               throws IOException

Throws:

IOException

suspendRs

protected void suspendRs(org.apache.hadoop.hbase.ServerName server)
                  throws IOException

Throws:

IOException

resumeRs

protected void resumeRs(org.apache.hadoop.hbase.ServerName server)
                 throws IOException

Throws:

IOException

killRs

protected void killRs(org.apache.hadoop.hbase.ServerName server)
               throws IOException

Throws:

IOException

startRs

protected void startRs(org.apache.hadoop.hbase.ServerName server)
                throws IOException

Throws:

IOException

killZKNode

protected void killZKNode(org.apache.hadoop.hbase.ServerName server)
                   throws IOException

Throws:

IOException

startZKNode

protected void startZKNode(org.apache.hadoop.hbase.ServerName server)
                    throws IOException

Throws:

IOException

killDataNode

protected void killDataNode(org.apache.hadoop.hbase.ServerName server)
                     throws IOException

Throws:

IOException

startDataNode

protected void startDataNode(org.apache.hadoop.hbase.ServerName server)
                      throws IOException

Throws:

IOException

killNameNode

protected void killNameNode(org.apache.hadoop.hbase.ServerName server)
                     throws IOException

Throws:

IOException

startNameNode

protected void startNameNode(org.apache.hadoop.hbase.ServerName server)
                      throws IOException

Throws:

IOException

killJournalNode

protected void killJournalNode(org.apache.hadoop.hbase.ServerName server)
                        throws IOException

Throws:

IOException

startJournalNode

protected void startJournalNode(org.apache.hadoop.hbase.ServerName server)
                         throws IOException

Throws:

IOException

unbalanceRegions

protected void unbalanceRegions(org.apache.hadoop.hbase.ClusterMetrics clusterStatus,
 List<org.apache.hadoop.hbase.ServerName> fromServers,
 List<org.apache.hadoop.hbase.ServerName> toServers,
 double fractionOfRegions)
                         throws Exception

Throws:

Exception

forceBalancer

protected void forceBalancer()
                      throws Exception

Throws:

Exception

setBalancer

protected void setBalancer(boolean onOrOff,
 boolean synchronous)
                    throws Exception

Throws:

Exception

getConf

public org.apache.hadoop.conf.Configuration getConf()

modifyAllTableColumns

protected void modifyAllTableColumns(org.apache.hadoop.hbase.TableName tableName,
 BiConsumer<String,org.apache.hadoop.hbase.client.ColumnFamilyDescriptorBuilder> transform)
                              throws IOException

Apply a transform to all columns in a given table. If there are no columns in a table or if the context is stopping does nothing.

Parameters:

tableName - the table to modify

transform - the modification to perform. Callers will have the column name as a string and a column family builder available to them

Throws:

IOException

modifyAllTableColumns

protected void modifyAllTableColumns(org.apache.hadoop.hbase.TableName tableName,
 Consumer<org.apache.hadoop.hbase.client.ColumnFamilyDescriptorBuilder> transform)
                              throws IOException

Apply a transform to all columns in a given table. If there are no columns in a table or if the context is stopping does nothing.

Parameters:

tableName - the table to modify

transform - the modification to perform on each column family descriptor builder

Throws:

IOException