Package org.apache.hadoop.hbase.backup

Class TestBackupDeleteWithContinuousBackupAndPITR

java.lang.Object

org.apache.hadoop.hbase.backup.TestBackupBase

org.apache.hadoop.hbase.backup.TestBackupDeleteWithContinuousBackupAndPITR

@Tag("org.apache.hadoop.hbase.testclassification.LargeTests")
public class TestBackupDeleteWithContinuousBackupAndPITR
extends TestBackupBase

Tests the deletion of HBase backups under continuous backup and PITR settings.

Terminology:

• ct (current time): Current timestamp
• maxAllowedPITRTime (mapt): Maximum allowed time range for PITR, typically a cluster-level config (e.g., 30 days ago)
• cst (continuousBackupStartTime): Earliest time from which continuous backup is available
• fs: Full backup start time (not reliably usable)
• fm: Time when snapshot (logical freeze) was taken (we don't have this)
• fe: Full backup end time (used as conservative proxy for fm)

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.backup.TestBackupBase

TestBackupBase.FullTableBackupClientForTest, TestBackupBase.IncrementalTableBackupClientForTest

Field Summary

Fields

Modifier and Type	Field	Description
private org.apache.hadoop.hbase.backup.impl.BackupSystemTable	backupSystemTable

Fields inherited from class org.apache.hadoop.hbase.backup.TestBackupBase

autoRestoreOnFailure, BACKUP_REMOTE_ROOT_DIR, BACKUP_ROOT_DIR, conf1, conf2, famName, NB_ROWS_IN_BATCH, provider, qualName, secure, table1, table1_restore, table1Desc, table2, table2_restore, table3, table3_restore, table4, TEST_UTIL, TEST_UTIL2, useSecondCluster

Constructor Summary

Constructors

Constructor	Description
TestBackupDeleteWithContinuousBackupAndPITR()

Method Summary

Modifier and Type	Method	Description
private void	assertDeletionFails(org.apache.hadoop.hbase.backup.impl.BackupSystemTable table, String backupId)
private void	assertDeletionSucceeds(org.apache.hadoop.hbase.backup.impl.BackupSystemTable table, String backupId, boolean isForceDelete)
private boolean	backupExists(org.apache.hadoop.hbase.backup.impl.BackupSystemTable table, String backupId)
private String[]	buildBackupDeleteArgs(String backupId, boolean isForceDelete)
private void	cleanupContinuousBackup()
private void	configureContinuousBackup(long cstTimestamp)	Configures continuous backup with the specified CST (continuous backup start time).
private String	createAndUpdateBackup(long startTs, long completeTs)	Creates a full backup and updates its timestamps.
private int	deleteBackup(String backupId, boolean isForceDelete)
private org.apache.hadoop.hbase.backup.BackupInfo	getBackupInfoById(String backupId)
void	testDeleteFullBackupNonContinuousTable()
void	testDeleteIncrementalBackup()
void	testDeletionWhenBackupAfterCST_ShouldFailUnlessCovered()	Main Case: continuousBackupStartTime >= maxAllowedPITRTime
void	testDeletionWhenBackupBeforeCST_ShouldSucceed()	Main Case: continuousBackupStartTime >= maxAllowedPITRTime
void	testDeletionWhenBackupCompletesBeforeCST()	Main Case: continuousBackupStartTime < maxAllowedPITRTime
void	testDeletionWhenBackupExtendsBeyondMAPTAndUncovered()	Main Case: continuousBackupStartTime < maxAllowedPITRTime
void	testDeletionWhenBackupStraddlesCST()	Main Case: continuousBackupStartTime < maxAllowedPITRTime
void	testDeletionWhenBackupWithinCSTToMAPTRangeAndUncovered()	Main Case: continuousBackupStartTime < maxAllowedPITRTime

Methods inherited from class org.apache.hadoop.hbase.backup.TestBackupBase

backupTables, backupTables, checkFailed, checkSucceeded, createBackupRequest, createBackupRequest, createBackupRequest, createTables, deleteContinuousBackupReplicationPeerIfExists, dumpBackupDir, fullTableBackup, getBackupAdmin, getLatestBackupManifest, getListOfWALFiles, incrementalTableBackup, insertIntoTable, loadTable, setUp, setUpHelper, tearDown, toList

Methods inherited from class java.lang.Object

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

Field Details

backupSystemTable

private org.apache.hadoop.hbase.backup.impl.BackupSystemTable backupSystemTable

Constructor Details

TestBackupDeleteWithContinuousBackupAndPITR

public TestBackupDeleteWithContinuousBackupAndPITR()

Method Details

configureContinuousBackup

private void configureContinuousBackup(long cstTimestamp)
                                throws IOException

Configures continuous backup with the specified CST (continuous backup start time).

Throws:

IOException

cleanupContinuousBackup

private void cleanupContinuousBackup()
                              throws IOException

Throws:

IOException

testDeletionWhenBackupCompletesBeforeCST

@Test
public void testDeletionWhenBackupCompletesBeforeCST()
                                              throws Exception

Main Case: continuousBackupStartTime < maxAllowedPITRTime

Sub Case: fe < cst

Throws:

Exception

testDeletionWhenBackupStraddlesCST

@Test
public void testDeletionWhenBackupStraddlesCST()
                                        throws Exception

Main Case: continuousBackupStartTime < maxAllowedPITRTime

Sub Case: fs < cst < fe

Throws:

Exception

testDeletionWhenBackupWithinCSTToMAPTRangeAndUncovered

@Test
public void testDeletionWhenBackupWithinCSTToMAPTRangeAndUncovered()
                                                            throws Exception

Main Case: continuousBackupStartTime < maxAllowedPITRTime

Sub Case: fs >= cst && fe < mapt

Throws:

Exception

testDeletionWhenBackupExtendsBeyondMAPTAndUncovered

@Test
public void testDeletionWhenBackupExtendsBeyondMAPTAndUncovered()
                                                         throws Exception

Main Case: continuousBackupStartTime < maxAllowedPITRTime

Sub Case: fs >= cst && fe >= mapt

Throws:

Exception

testDeletionWhenBackupBeforeCST_ShouldSucceed

@Test
public void testDeletionWhenBackupBeforeCST_ShouldSucceed()
                                                   throws Exception

Main Case: continuousBackupStartTime >= maxAllowedPITRTime

Sub Case: fs < cst

Throws:

Exception

testDeletionWhenBackupAfterCST_ShouldFailUnlessCovered

@Test
public void testDeletionWhenBackupAfterCST_ShouldFailUnlessCovered()
                                                            throws Exception

Main Case: continuousBackupStartTime >= maxAllowedPITRTime

Sub Case: fs >= cst

Throws:

Exception

testDeleteIncrementalBackup

@Test
public void testDeleteIncrementalBackup()
                                 throws Exception

Throws:

Exception

testDeleteFullBackupNonContinuousTable

@Test
public void testDeleteFullBackupNonContinuousTable()
                                            throws Exception

Throws:

Exception

createAndUpdateBackup

private String createAndUpdateBackup(long startTs,
 long completeTs)
                              throws Exception

Creates a full backup and updates its timestamps.

Throws:

Exception

assertDeletionSucceeds

private void assertDeletionSucceeds(org.apache.hadoop.hbase.backup.impl.BackupSystemTable table,
 String backupId,
 boolean isForceDelete)
                             throws Exception

Throws:

Exception

assertDeletionFails

private void assertDeletionFails(org.apache.hadoop.hbase.backup.impl.BackupSystemTable table,
 String backupId)
                          throws Exception

Throws:

Exception

backupExists

private boolean backupExists(org.apache.hadoop.hbase.backup.impl.BackupSystemTable table,
 String backupId)
                      throws Exception

Throws:

Exception

deleteBackup

private int deleteBackup(String backupId,
 boolean isForceDelete)
                  throws Exception

Throws:

Exception

buildBackupDeleteArgs

private String[] buildBackupDeleteArgs(String backupId,
 boolean isForceDelete)

getBackupInfoById

private org.apache.hadoop.hbase.backup.BackupInfo getBackupInfoById(String backupId)
                                                             throws IOException

Throws:

IOException