Package org.apache.hadoop.hbase.coprocessor

Class TestNegativeMemStoreSizeWithSlowCoprocessor

java.lang.Object

org.apache.hadoop.hbase.coprocessor.TestNegativeMemStoreSizeWithSlowCoprocessor

@Tag("org.apache.hadoop.hbase.testclassification.MediumTests")
public class TestNegativeMemStoreSizeWithSlowCoprocessor
extends Object

Test that verifies we do not have memstore size negative when a postPut/Delete hook is slow/expensive and a flush is triggered at the same time the coprocessow is doing its work. To simulate this we call flush from the coprocessor itself

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	TestNegativeMemStoreSizeWithSlowCoprocessor.FlushingRegionObserver

Field Summary

Fields

Modifier and Type	Field	Description
private static final byte[]	family
(package private) static final org.slf4j.Logger	LOG
private static final byte[]	qualifier
private static final byte[]	tableName
private static final HBaseTestingUtil	TEST_UTIL

Constructor Summary

Constructors

Constructor	Description
TestNegativeMemStoreSizeWithSlowCoprocessor()

Method Summary

Modifier and Type	Method	Description
static void	setupBeforeClass()
static void	tearDownAfterClass()
void	testNegativeMemstoreSize()

Methods inherited from class java.lang.Object

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

Field Details

LOG

static final org.slf4j.Logger LOG

TEST_UTIL

private static final HBaseTestingUtil TEST_UTIL

tableName

private static final byte[] tableName

family

private static final byte[] family

qualifier

private static final byte[] qualifier

Constructor Details

TestNegativeMemStoreSizeWithSlowCoprocessor

public TestNegativeMemStoreSizeWithSlowCoprocessor()

Method Details

setupBeforeClass

@BeforeAll
public static void setupBeforeClass()
                             throws Exception

Throws:

Exception

tearDownAfterClass

@AfterAll
public static void tearDownAfterClass()
                               throws Exception

Throws:

Exception

testNegativeMemstoreSize

@Test
public void testNegativeMemstoreSize()
                              throws IOException,
InterruptedException

Throws:

IOException

InterruptedException