Package org.apache.hadoop.hbase.procedure2

Class ProcedureExecutor.WorkerMonitor

java.lang.Object

org.apache.hadoop.hbase.procedure2.util.DelayedUtil.DelayedObject

org.apache.hadoop.hbase.procedure2.InlineChore

org.apache.hadoop.hbase.procedure2.ProcedureExecutor.WorkerMonitor

All Implemented Interfaces:

Comparable<Delayed>, Runnable, Delayed, DelayedUtil.DelayedWithTimeout

Enclosing class:

ProcedureExecutor<TEnvironment>

private final class ProcedureExecutor.WorkerMonitor
extends InlineChore

Field Summary

Fields

Modifier and Type	Field	Description
private float	addWorkerStuckPercentage
private static final float	DEFAULT_WORKER_ADD_STUCK_PERCENTAGE
private static final int	DEFAULT_WORKER_MONITOR_INTERVAL
private static final int	DEFAULT_WORKER_STUCK_THRESHOLD
private int	stuckThreshold
private int	timeoutInterval
static final String	WORKER_ADD_STUCK_PERCENTAGE_CONF_KEY
static final String	WORKER_MONITOR_INTERVAL_CONF_KEY
static final String	WORKER_STUCK_THRESHOLD_CONF_KEY

Constructor Summary

Constructors

Constructor	Description
WorkerMonitor()

Method Summary

Modifier and Type	Method	Description
private int	checkForStuckWorkers()
private void	checkThreadCount(int stuckCount)
int	getTimeoutInterval()
private void	refreshConfig()
void	run()

Methods inherited from class org.apache.hadoop.hbase.procedure2.InlineChore

getTimeout, refreshTimeout

Methods inherited from class org.apache.hadoop.hbase.procedure2.util.DelayedUtil.DelayedObject

compareTo, getDelay, toString

Methods inherited from class java.lang.Object

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

Field Details

WORKER_MONITOR_INTERVAL_CONF_KEY

public static final String WORKER_MONITOR_INTERVAL_CONF_KEY

See Also:

• Constant Field Values

DEFAULT_WORKER_MONITOR_INTERVAL

private static final int DEFAULT_WORKER_MONITOR_INTERVAL

See Also:

• Constant Field Values

WORKER_STUCK_THRESHOLD_CONF_KEY

public static final String WORKER_STUCK_THRESHOLD_CONF_KEY

See Also:

• Constant Field Values

DEFAULT_WORKER_STUCK_THRESHOLD

private static final int DEFAULT_WORKER_STUCK_THRESHOLD

See Also:

• Constant Field Values

WORKER_ADD_STUCK_PERCENTAGE_CONF_KEY

public static final String WORKER_ADD_STUCK_PERCENTAGE_CONF_KEY

See Also:

• Constant Field Values

DEFAULT_WORKER_ADD_STUCK_PERCENTAGE

private static final float DEFAULT_WORKER_ADD_STUCK_PERCENTAGE

See Also:

• Constant Field Values

addWorkerStuckPercentage

private float addWorkerStuckPercentage

timeoutInterval

private int timeoutInterval

stuckThreshold

private int stuckThreshold

Constructor Details

WorkerMonitor

public WorkerMonitor()

Method Details

run

public void run()

checkForStuckWorkers

private int checkForStuckWorkers()

checkThreadCount

private void checkThreadCount(int stuckCount)

refreshConfig

private void refreshConfig()

getTimeoutInterval

public int getTimeoutInterval()

Specified by:

getTimeoutInterval in class InlineChore