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.UncaughtExceptionHandler
Nested 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, zooKeeper
Fields inherited from class java.lang.Thread
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionprotected void
handleReportForDutyResponse
(org.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RegionServerStartupResponse c) Methods inherited from class org.apache.hadoop.hbase.MiniHBaseCluster.MiniHBaseClusterRegionServer
abort, kill, run
Methods 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, walRollRequestFinished
Methods 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, yield
Methods inherited from class java.lang.Object
equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
Methods inherited from interface org.apache.hadoop.hbase.Abortable
abort
-
Constructor Details
-
RegisterAndDieRegionServer
public RegisterAndDieRegionServer(org.apache.hadoop.conf.Configuration conf) throws IOException, InterruptedException - Throws:
IOException
InterruptedException
-
-
Method Details
-
handleReportForDutyResponse
protected void handleReportForDutyResponse(org.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RegionServerStartupResponse c) throws IOException - Overrides:
handleReportForDutyResponse
in classMiniHBaseCluster.MiniHBaseClusterRegionServer
- Throws:
IOException
-