Package org.apache.hadoop.hbase.regionserver

Class TestCompactionArchiveConcurrentClose

java.lang.Object

org.apache.hadoop.hbase.regionserver.TestCompactionArchiveConcurrentClose

@Tag("org.apache.hadoop.hbase.testclassification.RegionServerTests") @Tag("org.apache.hadoop.hbase.testclassification.SmallTests")
public class TestCompactionArchiveConcurrentClose
extends Object

Tests a race condition between archiving of compacted files in CompactedHFilesDischarger chore and HRegion.close();

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	TestCompactionArchiveConcurrentClose.WaitingStoreFileTracker

Field Summary

Fields

Modifier and Type	Field	Description
private AtomicBoolean	archived
private String	name
private static final AtomicBoolean	STATIC_ARCHIVED
private org.apache.hadoop.fs.Path	testDir
private HBaseTestingUtil	testUtil

Constructor Summary

Constructors

Constructor	Description
TestCompactionArchiveConcurrentClose()

Method Summary

Modifier and Type	Method	Description
private org.apache.hadoop.hbase.regionserver.HRegion	initHRegion(org.apache.hadoop.hbase.client.TableDescriptor htd, org.apache.hadoop.hbase.client.RegionInfo info)
void	setup(org.junit.jupiter.api.TestInfo testInfo)
void	tearDown()
void	testStoreCloseAndDischargeRunningInParallel()

Methods inherited from class java.lang.Object

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

Field Details

testUtil

private HBaseTestingUtil testUtil

testDir

private org.apache.hadoop.fs.Path testDir

archived

private AtomicBoolean archived

STATIC_ARCHIVED

private static final AtomicBoolean STATIC_ARCHIVED

name

private String name

Constructor Details

TestCompactionArchiveConcurrentClose

public TestCompactionArchiveConcurrentClose()

Method Details

setup

@BeforeEach
public void setup(org.junit.jupiter.api.TestInfo testInfo)
           throws Exception

Throws:

Exception

tearDown

@AfterEach
public void tearDown()
              throws Exception

Throws:

Exception

testStoreCloseAndDischargeRunningInParallel

@Test
public void testStoreCloseAndDischargeRunningInParallel()
                                                 throws Exception

Throws:

Exception

initHRegion

private org.apache.hadoop.hbase.regionserver.HRegion initHRegion(org.apache.hadoop.hbase.client.TableDescriptor htd,
 org.apache.hadoop.hbase.client.RegionInfo info)
                                                          throws IOException

Throws:

IOException