Class TestRSKilledWhenInitializing.RegisterAndDieRegionServer
java.lang.Object
java.lang.Thread
org.apache.hadoop.hbase.regionserver.HRegionServer
org.apache.hadoop.hbase.MiniHBaseCluster.MiniHBaseClusterRegionServer
org.apache.hadoop.hbase.regionserver.TestRSKilledWhenInitializing.RegisterAndDieRegionServer
- All Implemented Interfaces:
Runnable,org.apache.hadoop.hbase.Abortable,org.apache.hadoop.hbase.conf.ConfigurationObserver,org.apache.hadoop.hbase.regionserver.FavoredNodesForRegion,org.apache.hadoop.hbase.regionserver.LastSequenceId,org.apache.hadoop.hbase.regionserver.MutableOnlineRegions,org.apache.hadoop.hbase.regionserver.OnlineRegions,org.apache.hadoop.hbase.regionserver.RegionServerServices,org.apache.hadoop.hbase.Server,org.apache.hadoop.hbase.Stoppable
- Enclosing class:
- TestRSKilledWhenInitializing
static class TestRSKilledWhenInitializing.RegisterAndDieRegionServer
extends MiniHBaseCluster.MiniHBaseClusterRegionServer
A RegionServer that reports for duty and then immediately dies if it is the first to receive
the response to a reportForDuty. When it dies, it clears its ephemeral znode which the master
notices and so removes the region from its set of online regionservers.
-
Nested Class Summary
Nested classes/interfaces inherited from class java.lang.Thread
Thread.State, Thread.UncaughtExceptionHandlerNested classes/interfaces inherited from interface org.apache.hadoop.hbase.regionserver.RegionServerServices
org.apache.hadoop.hbase.regionserver.RegionServerServices.PostOpenDeployContext, org.apache.hadoop.hbase.regionserver.RegionServerServices.RegionStateTransitionContext -
Field Summary
Fields inherited from class org.apache.hadoop.hbase.regionserver.HRegionServer
clusterConnection, clusterId, clusterStatusTracker, conf, configurationManager, executorService, infoServer, REGIONSERVER, rpcServices, serverName, sleeper, startcode, tableDescriptors, TEST_SKIP_REPORTING_TRANSITION, useThisHostnameInstead, zooKeeperFields inherited from class java.lang.Thread
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected voidhandleReportForDutyResponse(org.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RegionServerStartupResponse c) Methods inherited from class org.apache.hadoop.hbase.MiniHBaseCluster.MiniHBaseClusterRegionServer
abort, kill, runMethods inherited from class org.apache.hadoop.hbase.regionserver.HRegionServer
addRegion, cacheTableDescriptor, canCreateBaseZNode, canUpdateTableDescriptor, closeRegion, configureInfoServer, createClusterConnection, createConnection, createRegionLoad, createRegionServerStatusStub, createRpcServices, dumpRowLocks, finishRegionProcedure, getAccessChecker, getActiveMaster, getBackupMasters, getBlockCache, getBootstrapNodes, getBrokenStoreFileCleaner, getChoreService, getClusterConnection, getClusterId, getCompactedHFilesDischarger, getCompactionPressure, getCompactionRequestor, getCompactSplitThread, getConfiguration, getConfigurationManager, getConnection, getCoordinatedStateManager, getDataRootDir, getDumpServlet, getEventLoopGroupConfig, getExecutorService, getFavoredNodesForRegion, getFileSystem, getFlushPressure, getFlushRequester, getFlushThroughputController, getHeapMemoryManager, getInfoServer, getLastSequenceId, getLeaseManager, getMasterAddressTracker, getMemStoreFlusher, getMetaRegionLocationCache, getMetrics, getMobFileCache, getMovedRegion, getNamedQueueRecorder, getNonceManager, getNumberOfOnlineRegions, getOnlineRegion, getOnlineRegions, getOnlineRegionsLocalContext, getOnlineTables, getProcessName, getRegion, getRegion, getRegionByEncodedName, getRegions, getRegions, getRegionServerAccounting, getRegionServerCoprocessorHost, getRegionServerCoprocessors, getRegionServerRpcQuotaManager, getRegionServerSpaceQuotaManager, getRegionsInTransitionInRS, getReplicationSourceService, getRetryPauseTime, getRpcServer, getRSMobFileCleanerChore, getRSRpcServices, getSecureBulkLoadManager, getServerName, getStartcode, getTableDescriptors, getUseThisHostnameInstead, getWAL, getWALFileSystem, getWalGroupsReplicationStatus, getWalRoller, getWALRootDir, getWALs, getZKPermissionWatcher, getZooKeeper, initializeMemStoreChunkCreator, isAborted, isClusterUp, isOnline, isShutDown, isShutdownHookInstalled, isStopped, isStopping, login, main, movedRegionCacheExpiredTime, onConfigurationChange, postOpenDeployTasks, postUpdateConfiguration, preUpdateConfiguration, regionLock, registerService, remoteProcedureComplete, removeRegion, reportFileArchivalForQuotas, reportRegionSizesForQuotas, reportRegionStateTransition, setAbortRequested, setupClusterConnection, shutdownChore, stop, stop, stopServiceThreads, toString, tryRegionServerReport, unassign, updateRegionFavoredNodesMapping, waitForMasterActive, waitForServerOnline, walRollRequestFinishedMethods inherited from class java.lang.Thread
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, yieldMethods inherited from class java.lang.Object
equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitMethods inherited from interface org.apache.hadoop.hbase.Abortable
abort
-
Constructor Details
-
RegisterAndDieRegionServer
public RegisterAndDieRegionServer(org.apache.hadoop.conf.Configuration conf) throws IOException, InterruptedException - Throws:
IOExceptionInterruptedException
-
-
Method Details
-
handleReportForDutyResponse
protected void handleReportForDutyResponse(org.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RegionServerStartupResponse c) throws IOException - Overrides:
handleReportForDutyResponsein classMiniHBaseCluster.MiniHBaseClusterRegionServer- Throws:
IOException
-