org.apache.hadoop.hbase

Class ZNodeClearer

java.lang.Object

org.apache.hadoop.hbase.ZNodeClearer

@InterfaceAudience.Private
public final class ZNodeClearer
extends Object

Contains a set of methods for the collaboration between the start/stop scripts and the servers. It allows to delete immediately the znode when the master or the regions server crashes. The region server / master writes a specific file when it starts / becomes main master. When they end properly, they delete the file.

In the script, we check for the existence of these files when the program ends. If they still exist we conclude that the server crashed, likely without deleting their znode. To have a faster recovery we delete immediately the znode.

The strategy depends on the server type. For a region server we store the znode path in the file, and use it to delete it. for a master, as the znode path constant whatever the server, we check its content to make sure that the backup server is not now in charge.

Field Summary

Fields

Modifier and Type	Field and Description
private static org.slf4j.Logger	LOG

Constructor Summary

Constructors

Modifier	Constructor and Description
private	ZNodeClearer()

Method Summary

Modifier and Type	Method and Description
static boolean	clear(org.apache.hadoop.conf.Configuration conf) Delete the master znode if its content (ServerName string) is the same as the one in the znode file.
static void	deleteMyEphemeralNodeOnDisk() delete the znode file
static String	getMyEphemeralNodeFileName() Get the name of the file used to store the znode contents
static String	parseMasterServerName(String rsZnodePath) See HBASE-14861.
static String	readMyEphemeralNodeOnDisk() read the content of znode file, expects a single line.
private static boolean	tablesOnMaster(org.apache.hadoop.conf.Configuration conf)
static void	writeMyEphemeralNodeOnDisk(String fileContent) Logs the errors without failing on exception.

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

Constructor Detail

ZNodeClearer

private ZNodeClearer()

Method Detail

writeMyEphemeralNodeOnDisk

public static void writeMyEphemeralNodeOnDisk(String fileContent)

Logs the errors without failing on exception.

readMyEphemeralNodeOnDisk

public static String readMyEphemeralNodeOnDisk()
                                        throws IOException

read the content of znode file, expects a single line.

Throws:

IOException

getMyEphemeralNodeFileName

public static String getMyEphemeralNodeFileName()

Get the name of the file used to store the znode contents

deleteMyEphemeralNodeOnDisk

public static void deleteMyEphemeralNodeOnDisk()

delete the znode file

parseMasterServerName

public static String parseMasterServerName(String rsZnodePath)

See HBASE-14861. We are extracting master ServerName from rsZnodePath example: "/hbase/rs/server.example.com,16020,1448266496481"

Parameters:

rsZnodePath - from HBASE_ZNODE_FILE

Returns:

String representation of ServerName or null if fails

tablesOnMaster

private static boolean tablesOnMaster(org.apache.hadoop.conf.Configuration conf)

Returns:

true if cluster is configured with master-rs collocation

clear

public static boolean clear(org.apache.hadoop.conf.Configuration conf)

Delete the master znode if its content (ServerName string) is the same as the one in the znode file. (env: HBASE_ZNODE_FILE). I case of master-rs colloaction we extract ServerName string from rsZnode path.(HBASE-14861)

Returns:

true on successful deletion, false otherwise.