org.apache.hadoop.hbase.master

Class RegionServerTracker

java.lang.Object

org.apache.hadoop.hbase.zookeeper.ZKListener

org.apache.hadoop.hbase.master.RegionServerTracker

@InterfaceAudience.Private
public class RegionServerTracker
extends ZKListener

Tracks the online region servers via ZK.

Handling of new RSs checking in is done via RPC. This class is only responsible for watching for expired nodes. It handles listening for changes in the RS node list. The only exception is when master restart, we will use the list fetched from zk to construct the initial set of live region servers.

If an RS node gets deleted, this automatically handles calling of ServerManager.expireServer(ServerName)

Field Summary

Fields

Modifier and Type	Field and Description
private ExecutorService	executor
private static org.slf4j.Logger	LOG
private Set<ServerName>	regionServers
private MasterServices	server
private ServerManager	serverManager

Fields inherited from class org.apache.hadoop.hbase.zookeeper.ZKListener

watcher

Constructor Summary

Constructors

Constructor and Description
RegionServerTracker(ZKWatcher watcher, MasterServices server, ServerManager serverManager)

Method Summary

Modifier and Type	Method and Description
private Pair<ServerName,org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionServerInfo>	getServerInfo(String name)
void	nodeChildrenChanged(String path) Called when an existing node has a child node added or removed.
private void	refresh()
void	start(Set<ServerName> deadServersFromPE, Set<ServerName> liveServersFromWALDir, Set<ServerName> splittingServersFromWALDir) Starts the tracking of online RegionServers.
void	stop()

Methods inherited from class org.apache.hadoop.hbase.zookeeper.ZKListener

getWatcher, nodeCreated, nodeDataChanged, nodeDeleted

Methods inherited from class java.lang.Object

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

Field Detail

LOG

private static final org.slf4j.Logger LOG

regionServers

private final Set<ServerName> regionServers

serverManager

private final ServerManager serverManager

server

private final MasterServices server

executor

private final ExecutorService executor

Constructor Detail

RegionServerTracker

public RegionServerTracker(ZKWatcher watcher,
                           MasterServices server,
                           ServerManager serverManager)

Method Detail

getServerInfo

private Pair<ServerName,org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionServerInfo> getServerInfo(String name)
                                                                                                               throws org.apache.zookeeper.KeeperException,
                                                                                                                      IOException

Throws:

org.apache.zookeeper.KeeperException

IOException

start

public void start(Set<ServerName> deadServersFromPE,
                  Set<ServerName> liveServersFromWALDir,
                  Set<ServerName> splittingServersFromWALDir)
           throws org.apache.zookeeper.KeeperException,
                  IOException

Starts the tracking of online RegionServers. All RSes will be tracked after this method is called.

In this method, we will also construct the region server sets in ServerManager. If a region server is dead between the crash of the previous master instance and the start of the current master instance, we will schedule a SCP for it. This is done in ServerManager.findDeadServersAndProcess(Set, Set), we call it here under the lock protection to prevent concurrency issues with server expiration operation.

Parameters:

deadServersFromPE - the region servers which already have SCP associated.

liveServersFromWALDir - the live region servers from wal directory.

splittingServersFromWALDir - Servers whose WALs are being actively 'split'.

Throws:

org.apache.zookeeper.KeeperException

IOException

stop

public void stop()

refresh

private void refresh()

nodeChildrenChanged

public void nodeChildrenChanged(String path)

Description copied from class: ZKListener

Called when an existing node has a child node added or removed.

Overrides:

nodeChildrenChanged in class ZKListener

Parameters:

path - full path of the node whose children have changed