org.apache.hadoop.hbase.util

Class HBaseFsckRepair

java.lang.Object

org.apache.hadoop.hbase.util.HBaseFsckRepair

@InterfaceAudience.Private
public class HBaseFsckRepair
extends Object

This class contains helper methods that repair parts of hbase's filesystem contents.

Field Summary

Fields

Modifier and Type	Field and Description
static Log	LOG

Constructor Summary

Constructors

Constructor and Description
HBaseFsckRepair()

Method Summary

Modifier and Type	Method and Description
static void	closeRegionSilentlyAndWait(HConnection connection, ServerName server, HRegionInfo region) Contacts a region server and waits up to hbase.hbck.close.timeout ms (default 120s) to close the region.
static HRegion	createHDFSRegionDir(Configuration conf, HRegionInfo hri, HTableDescriptor htd) Creates, flushes, and closes a new region.
static void	fixMetaHoleOnlineAndAddReplicas(Configuration conf, HRegionInfo hri, Collection<ServerName> servers, int numReplicas) Puts the specified HRegionInfo into META with replica related columns
static void	fixMultiAssignment(HConnection connection, HRegionInfo region, List<ServerName> servers) Fix multiple assignment by doing silent closes on each RS hosting the region and then force ZK unassigned node to OFFLINE to trigger assignment by master.
static void	fixUnassigned(Admin admin, HRegionInfo region) Fix unassigned by creating/transition the unassigned ZK node for this region to OFFLINE state with a special flag to tell the master that this is a forced operation by HBCK.
static void	waitUntilAssigned(Admin admin, HRegionInfo region)

Methods inherited from class java.lang.Object

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

Field Detail

LOG

public static final Log LOG

Constructor Detail

HBaseFsckRepair

public HBaseFsckRepair()

Method Detail

fixMultiAssignment

public static void fixMultiAssignment(HConnection connection,
                                      HRegionInfo region,
                                      List<ServerName> servers)
                               throws IOException,
                                      KeeperException,
                                      InterruptedException

Fix multiple assignment by doing silent closes on each RS hosting the region and then force ZK unassigned node to OFFLINE to trigger assignment by master.

Parameters:

connection - HBase connection to the cluster

region - Region to undeploy

servers - list of Servers to undeploy from

Throws:

IOException

KeeperException

InterruptedException

fixUnassigned

public static void fixUnassigned(Admin admin,
                                 HRegionInfo region)
                          throws IOException,
                                 KeeperException,
                                 InterruptedException

Fix unassigned by creating/transition the unassigned ZK node for this region to OFFLINE state with a special flag to tell the master that this is a forced operation by HBCK. This assumes that info is in META.

Parameters:

admin -

region -

Throws:

IOException

KeeperException

InterruptedException

waitUntilAssigned

public static void waitUntilAssigned(Admin admin,
                                     HRegionInfo region)
                              throws IOException,
                                     InterruptedException

Throws:

IOException

InterruptedException

closeRegionSilentlyAndWait

public static void closeRegionSilentlyAndWait(HConnection connection,
                                              ServerName server,
                                              HRegionInfo region)
                                       throws IOException,
                                              InterruptedException

Contacts a region server and waits up to hbase.hbck.close.timeout ms (default 120s) to close the region. This bypasses the active hmaster.

Throws:

IOException

InterruptedException

fixMetaHoleOnlineAndAddReplicas

public static void fixMetaHoleOnlineAndAddReplicas(Configuration conf,
                                                   HRegionInfo hri,
                                                   Collection<ServerName> servers,
                                                   int numReplicas)
                                            throws IOException

Puts the specified HRegionInfo into META with replica related columns

Throws:

IOException

createHDFSRegionDir

public static HRegion createHDFSRegionDir(Configuration conf,
                                          HRegionInfo hri,
                                          HTableDescriptor htd)
                                   throws IOException

Creates, flushes, and closes a new region.

Throws:

IOException