public class OOMERegionServer extends org.apache.hadoop.hbase.regionserver.HRegionServer
put(byte[], Put)
is called, we add keep around
a reference to the batch. Use this class to test OOME extremes. Needs to be started manually as
in
${HBASE_HOME}/bin/hbase ./bin/hbase org.apache.hadoop.hbase.OOMERegionServer start
.Thread.State, Thread.UncaughtExceptionHandler
Modifier and Type | Field and Description |
---|---|
private List<org.apache.hadoop.hbase.client.Put> |
retainer |
ABORT_TIMEOUT, ABORT_TIMEOUT_TASK, compactedFileDischarger, metricsRegionServerImpl, nonceManager, online, REGIONSERVER, RS_HOSTNAME_DISABLE_MASTER_REVERSEDNS_KEY, TEST_SKIP_REPORTING_TRANSITION, unitKB, unitMB, UNSAFE_RS_HOSTNAME_DISABLE_MASTER_REVERSEDNS_KEY
abortRequested, asyncClusterConnection, choreService, clusterStatusTracker, conf, configurationManager, csm, dataFs, dataRootDir, eventLoopGroupConfig, executorService, infoServer, metaRegionLocationCache, msgInterval, namedQueueRecorder, rpcServices, serverName, sleeper, startcode, stopped, tableDescriptors, userProvider, useThisHostnameInstead, walFs, walRootDir, zooKeeper
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
Constructor and Description |
---|
OOMERegionServer(org.apache.hadoop.hbase.HBaseConfiguration conf) |
Modifier and Type | Method and Description |
---|---|
static void |
main(String[] args) |
void |
put(byte[] regionName,
org.apache.hadoop.hbase.client.Put put) |
abort, addRegion, buildRegionSpaceUseReportRequest, cacheTableDescriptor, canCreateBaseZNode, canUpdateTableDescriptor, checkFileSystem, clearRegionBlockCache, closeRegion, clusterMode, configureInfoServer, constructRegionServer, convertRegionSize, createNamedQueueRecord, createRegionLoad, createRegionLoad, createRegionServerStatusStub, createRpcServices, dumpRowLocks, execRegionServerService, executeProcedure, finishRegionProcedure, getActiveMaster, getBackupMasters, getBlockCache, getBootstrapNodes, getBrokenStoreFileCleaner, getClusterId, getCompactedHFilesDischarger, getCompactionPressure, getCompactionRequestor, getCompactSplitThread, getCoprocessorHost, getCopyOfOnlineRegionsSortedByOffHeapSize, getCopyOfOnlineRegionsSortedByOnHeapSize, getDumpServlet, getFavoredNodesForRegion, getFlushPressure, getFlushRequester, getFlushThroughputController, getHeapMemoryManager, getLastSequenceId, getLeaseManager, getMasterAddressTracker, getMemStoreFlusher, getMetaLocations, getMetrics, getMobFileCache, getMovedRegion, getNonceManager, getNumberOfOnlineRegions, getOnlineRegion, getOnlineRegions, getOnlineRegionsLocalContext, getOnlineTables, getProcessName, getRegion, getRegion, getRegionByEncodedName, getRegionReplicationBufferManager, getRegions, getRegions, getRegionServerAccounting, getRegionServerCoprocessorHost, getRegionServerCoprocessors, getRegionServerRpcQuotaManager, getRegionServerSpaceQuotaManager, getRegionsInTransitionInRS, getReplicationSinkService, getReplicationSourceService, getRetryPauseTime, getRSMobFileCleanerChore, getRSRpcServices, getRsSnapshotVerifier, getSecureBulkLoadManager, getUseThisHostnameInstead, getWAL, getWalFactory, getWalGroupsReplicationStatus, getWalRoller, getWALs, handleReportForDutyResponse, isClusterUp, isDataFileSystemOk, isOnline, isStopping, kill, login, movedRegionCacheExpiredTime, onConfigurationChange, postOpenDeployTasks, regionLock, registerService, remoteProcedureComplete, removeFromMovedRegions, removeRegion, reportFileArchivalForQuotas, reportProcedureDone, reportRegionSizesForQuotas, reportRegionStateTransition, run, stop, stop, stopChores, stopServiceThreads, submitRegionProcedure, tryRegionServerReport, unassign, updateRegionFavoredNodesMapping, waitForServerOnline, walRollRequestFinished
closeClusterConnection, closeTableDescriptors, closeZooKeeper, createConnection, getAccessChecker, getAsyncClusterConnection, getChoreService, getConfiguration, getConfigurationManager, getCoordinatedStateManager, getDataRootDir, getEventLoopGroupConfig, getExecutorService, getFileSystem, getInfoServer, getMetaRegionLocationCache, getMsgInterval, getNamedQueueRecorder, getRpcServer, getRpcServices, getServerName, getStartcode, getTableDescriptors, getWALFileSystem, getWALRootDir, getZKPermissionWatcher, getZooKeeper, initializeFileSystem, initializeMemStoreChunkCreator, installShutdownHook, isAborted, isShutdownHookInstalled, isStopped, setAbortRequested, setupClusterConnection, shutdownChore, stopChoreService, stopExecutorService, stopInfoServer, toString, updateConfiguration
activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, yield
equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getAccessChecker, getExecutorService, getRpcServer, getTableDescriptors, getZKPermissionWatcher
public OOMERegionServer(org.apache.hadoop.hbase.HBaseConfiguration conf) throws IOException, InterruptedException
IOException
InterruptedException
public void put(byte[] regionName, org.apache.hadoop.hbase.client.Put put) throws IOException
IOException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.