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>
-
Field Summary
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionprivate int
private void
checkThreadCount
(int stuckCount) int
private void
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
-
Field Details
-
WORKER_MONITOR_INTERVAL_CONF_KEY
- See Also:
-
DEFAULT_WORKER_MONITOR_INTERVAL
- See Also:
-
WORKER_STUCK_THRESHOLD_CONF_KEY
- See Also:
-
DEFAULT_WORKER_STUCK_THRESHOLD
- See Also:
-
WORKER_ADD_STUCK_PERCENTAGE_CONF_KEY
- See Also:
-
DEFAULT_WORKER_ADD_STUCK_PERCENTAGE
- See Also:
-
addWorkerStuckPercentage
-
timeoutInterval
-
stuckThreshold
-
-
Constructor Details
-
WorkerMonitor
public WorkerMonitor()
-
-
Method Details
-
run
-
checkForStuckWorkers
-
checkThreadCount
-
refreshConfig
-
getTimeoutInterval
- Specified by:
getTimeoutInterval
in classInlineChore
-