org.apache.hadoop.hbase.regionserver

Class TestRSKilledWhenInitializing.RegisterAndDieRegionServer

java.lang.Object

org.apache.hadoop.hbase.util.HasThread

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 org.apache.hadoop.hbase.regionserver.HRegionServer

org.apache.hadoop.hbase.regionserver.HRegionServer.MovedRegionsCleaner, org.apache.hadoop.hbase.regionserver.HRegionServer.PeriodicMemStoreFlusher

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

ABORT_TIMEOUT, ABORT_TIMEOUT_TASK, cacheConfig, cacheFlusher, clusterConnection, clusterId, clusterStatusTracker, compactedFileDischarger, compactionChecker, compactSplitThread, conf, configurationManager, csm, executorService, fs, fsOk, fsUtilizationChore, hMemManager, infoServer, killed, leases, lock, MASTER_HOSTNAME_KEY, MASTERLESS_CONFIG_NAME, metaTableLocator, metricsRegionServer, metricsTable, mobCacheConfig, movedRegions, msgInterval, nonceManager, numRegionsToReport, numRetries, online, onlineRegions, periodicFlusher, regionFavoredNodesMap, REGIONSERVER, regionsInTransitionInRS, replicationSinkHandler, replicationSourceHandler, rowlocks, rpcClient, rpcServices, RS_HOSTNAME_DISABLE_MASTER_REVERSEDNS_KEY, RS_HOSTNAME_KEY, secureBulkLoadManager, serverName, sleeper, startcode, tableDescriptors, TEST_SKIP_REPORTING_TRANSITION, threadWakeFrequency, useThisHostnameInstead, walFactory, walFs, walRoller, zooKeeper

Constructor Summary

Constructors

Constructor and Description
RegisterAndDieRegionServer(org.apache.hadoop.conf.Configuration conf)

Method Summary

Modifier and Type	Method and Description
protected 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

abort, addRegion, addToMovedRegions, buildRegionSpaceUseReportRequest, buildServerLoad, canCreateBaseZNode, canUpdateTableDescriptor, checkFileSystem, cleanMovedRegions, clearRegionBlockCache, closeAllRegions, closeAndOfflineRegionForSplitOrMerge, closeMetaTableRegions, closeRegion, closeUserRegions, configureInfoServer, constructRegionServer, convertRegionSize, convertThrowableToIOE, createClusterConnection, createConnection, createRegionLoad, createRegionLoad, createRegionServerStatusStub, createRegionServerStatusStub, createRpcServices, execRegionServerService, getCacheConfig, getChoreService, getClusterConnection, getClusterId, getCompactionPressure, getCompactionRequestor, getCompactSplitThread, getConfiguration, getConfigurationManager, getConnection, getCoordinatedStateManager, getCopyOfOnlineRegionsSortedByOffHeapSize, getCopyOfOnlineRegionsSortedByOnHeapSize, getDumpServlet, getEventLoopGroupConfig, getExecutorService, getFavoredNodesForRegion, getFileSystem, getFlushPressure, getFlushRequester, getFlushThroughputController, getFsTableDescriptors, getHeapMemoryManager, getInfoServer, getLastSequenceId, getLeases, getMasterAddressTracker, getMetaTableLocator, getMetaTableObserver, getMetrics, getMostLoadedRegions, getNonceManager, getNumberOfOnlineRegions, getOnlineRegion, getOnlineRegionsAsPrintableString, getOnlineRegionsLocalContext, getOnlineTables, getProcessName, getRegion, getRegion, getRegionBlockLocations, getRegionByEncodedName, getRegionByEncodedName, getRegions, getRegions, getRegionServerAccounting, getRegionServerCoprocessorHost, getRegionServerCoprocessors, getRegionServerMetrics, getRegionServerRpcQuotaManager, getRegionServerSpaceQuotaManager, getRegionsInTransitionInRS, getReplicationSinkService, getReplicationSourceService, getRootDir, getRpcServer, getRSRpcServices, getSecureBulkLoadManager, getServerName, getStartcode, getTableDescriptors, getThreadWakeFrequency, getUseThisHostnameInstead, getWAL, getWALFileSystem, getWalRoller, getWALRootDir, getWALs, getWriteLock, getZooKeeper, initializeMemStoreChunkCreator, isAborted, isClusterUp, isOnline, isOnlineRegionsEmpty, isStopped, isStopping, login, main, movedRegionCleanerPeriod, onConfigurationChange, postOpenDeployTasks, regionLock, registerService, removeFromMovedRegions, removeRegion, reportRegionSizesForQuotas, reportRegionStateTransition, sendShutdownInterrupt, setupClusterConnection, stop, stop, stopServiceThreads, toString, triggerFlushInPrimaryRegion, tryRegionServerReport, unassign, updateConfiguration, updateRegionFavoredNodesMapping, waitForMasterActive, waitForServerOnline, walRollRequestFinished

Methods inherited from class org.apache.hadoop.hbase.util.HasThread

getName, getThread, interrupt, isAlive, isInterrupted, join, join, join, setDaemon, setName, setPriority, setUncaughtExceptionHandler, start

Methods inherited from class java.lang.Object

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

Constructor Detail

RegisterAndDieRegionServer

public RegisterAndDieRegionServer(org.apache.hadoop.conf.Configuration conf)
                           throws IOException,
                                  InterruptedException

Throws:

IOException

InterruptedException

Method Detail

handleReportForDutyResponse

protected void handleReportForDutyResponse(org.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RegionServerStartupResponse c)
                                    throws IOException

Overrides:

handleReportForDutyResponse in class MiniHBaseCluster.MiniHBaseClusterRegionServer

Throws:

IOException