Package org.apache.hadoop.hbase.replication.master

Class TestReplicationLogCleaner

java.lang.Object
org.apache.hadoop.hbase.replication.master.TestReplicationLogCleaner
@Tag("org.apache.hadoop.hbase.testclassification.MasterTests") @Tag("org.apache.hadoop.hbase.testclassification.SmallTests") public class TestReplicationLogCleaner extends Object

  • Field Details

    • CONF

      private static final org.apache.hadoop.conf.Configuration CONF

    • services

      private org.apache.hadoop.hbase.master.MasterServices services

    • cleaner

      private org.apache.hadoop.hbase.replication.master.ReplicationLogCleaner cleaner

    • rpm

      private org.apache.hadoop.hbase.master.replication.ReplicationPeerManager rpm

  • Constructor Details

  • Method Details

    • setUp

      @BeforeEach public void setUp() throws org.apache.hadoop.hbase.replication.ReplicationException
      Throws:
      org.apache.hadoop.hbase.replication.ReplicationException

    • tearDown

      @AfterEach public void tearDown()

    • runCleaner

      private static Iterable<org.apache.hadoop.fs.FileStatus> runCleaner(org.apache.hadoop.hbase.replication.master.ReplicationLogCleaner cleaner, Iterable<org.apache.hadoop.fs.FileStatus> files)

    • createFileStatus

      private static org.apache.hadoop.fs.FileStatus createFileStatus(org.apache.hadoop.fs.Path path)

    • createFileStatus

      private static org.apache.hadoop.fs.FileStatus createFileStatus(org.apache.hadoop.hbase.ServerName sn, int number)

    • createPeer

      private static org.apache.hadoop.hbase.replication.ReplicationPeerDescription createPeer(String peerId)

    • addServer

      private void addServer(org.apache.hadoop.hbase.ServerName serverName)

    • addSCP

      private void addSCP(org.apache.hadoop.hbase.ServerName serverName, boolean finished)

    • addPeer

      private void addPeer(String... peerIds)

    • addQueueData

      private void addQueueData(org.apache.hadoop.hbase.replication.ReplicationQueueData... datas) throws org.apache.hadoop.hbase.replication.ReplicationException
      Throws:
      org.apache.hadoop.hbase.replication.ReplicationException

    • testNoConf

      @Test public void testNoConf()

    • testCanNotFilter

      @Test public void testCanNotFilter()

    • testNoPeer

      @Test public void testNoPeer()

    • testNotValidWalFile

      @Test public void testNotValidWalFile()

    • testMetaWalFile

      @Test public void testMetaWalFile()

    • testLiveRegionServerNoQueues

      @Test public void testLiveRegionServerNoQueues()

    • testLiveRegionServerWithSCPNoQueues

      @Test public void testLiveRegionServerWithSCPNoQueues()

    • testDeadRegionServerNoQueues

      @Test public void testDeadRegionServerNoQueues()

    • testDeadRegionServerWithSCPNoQueues

      @Test public void testDeadRegionServerWithSCPNoQueues()

    • testLiveRegionServerMissingQueue

      @Test public void testLiveRegionServerMissingQueue() throws org.apache.hadoop.hbase.replication.ReplicationException
      Throws:
      org.apache.hadoop.hbase.replication.ReplicationException

    • testLiveRegionServerShouldNotDelete

      @Test public void testLiveRegionServerShouldNotDelete() throws org.apache.hadoop.hbase.replication.ReplicationException
      Throws:
      org.apache.hadoop.hbase.replication.ReplicationException

    • testLiveRegionServerShouldNotDeleteTwoPeers

      @Test public void testLiveRegionServerShouldNotDeleteTwoPeers() throws org.apache.hadoop.hbase.replication.ReplicationException
      Throws:
      org.apache.hadoop.hbase.replication.ReplicationException

    • testLiveRegionServerShouldDelete

      @Test public void testLiveRegionServerShouldDelete() throws org.apache.hadoop.hbase.replication.ReplicationException
      Throws:
      org.apache.hadoop.hbase.replication.ReplicationException

    • testLiveRegionServerShouldDeleteTwoPeers

      @Test public void testLiveRegionServerShouldDeleteTwoPeers() throws org.apache.hadoop.hbase.replication.ReplicationException
      Throws:
      org.apache.hadoop.hbase.replication.ReplicationException

    • testDeadRegionServerMissingQueue

      @Test public void testDeadRegionServerMissingQueue() throws org.apache.hadoop.hbase.replication.ReplicationException
      Throws:
      org.apache.hadoop.hbase.replication.ReplicationException

    • testDeadRegionServerShouldNotDelete

      @Test public void testDeadRegionServerShouldNotDelete() throws org.apache.hadoop.hbase.replication.ReplicationException
      Throws:
      org.apache.hadoop.hbase.replication.ReplicationException

    • testDeadRegionServerShouldNotDeleteTwoPeers

      @Test public void testDeadRegionServerShouldNotDeleteTwoPeers() throws org.apache.hadoop.hbase.replication.ReplicationException
      Throws:
      org.apache.hadoop.hbase.replication.ReplicationException

    • testDeadRegionServerShouldDelete

      @Test public void testDeadRegionServerShouldDelete() throws org.apache.hadoop.hbase.replication.ReplicationException
      Throws:
      org.apache.hadoop.hbase.replication.ReplicationException

    • testDeadRegionServerShouldDeleteTwoPeers

      @Test public void testDeadRegionServerShouldDeleteTwoPeers() throws org.apache.hadoop.hbase.replication.ReplicationException
      Throws:
      org.apache.hadoop.hbase.replication.ReplicationException

    • testPreCleanWhenAsyncClusterConnectionClosed

      @Test public void testPreCleanWhenAsyncClusterConnectionClosed() throws org.apache.hadoop.hbase.replication.ReplicationException
      Throws:
      org.apache.hadoop.hbase.replication.ReplicationException

    • testGetDeletableFilesWhenAsyncClusterConnectionClosed

      @Test public void testGetDeletableFilesWhenAsyncClusterConnectionClosed() throws org.apache.hadoop.hbase.replication.ReplicationException
      Throws:
      org.apache.hadoop.hbase.replication.ReplicationException