HBASE-27405 Fix the replication hfile/log cleaner report that the replication table does not exist

Author: 2005hithlj

hbase-server/src/test/java/org/apache/hadoop/hbase/master/cleaner/TestLogsCleaner.java

@@ -58,6 +58,7 @@
 import org.apache.hadoop.hbase.testclassification.MediumTests;
 import org.apache.hadoop.hbase.util.Bytes;
 import org.apache.hadoop.hbase.util.EnvironmentEdgeManager;
+import org.apache.hadoop.hbase.util.FSTableDescriptors;
 import org.apache.hadoop.hbase.util.MockServer;
 import org.apache.hadoop.hbase.zookeeper.ZKWatcher;
 import org.junit.AfterClass;
@@ -124,6 +125,8 @@ public void beforeTest() throws Exception {
     fs.mkdirs(OLD_WALS_DIR);
 
     TableName tableName = tableNameRule.getTableName();
+    conf.set(ReplicationStorageFactory.REPLICATION_QUEUE_TABLE_NAME, tableName.getNameAsString());
+
     TableDescriptor td = ReplicationStorageFactory.createReplicationQueueTableDescriptor(tableName);
     TEST_UTIL.getAdmin().createTable(td);
     TEST_UTIL.waitTableAvailable(tableName);
@@ -134,6 +137,7 @@ public void beforeTest() throws Exception {
     when(masterServices.getConnection()).thenReturn(TEST_UTIL.getConnection());
     ReplicationPeerManager rpm = mock(ReplicationPeerManager.class);
     when(masterServices.getReplicationPeerManager()).thenReturn(rpm);
+    when(masterServices.getTableDescriptors()).thenReturn(new FSTableDescriptorsTest(conf));
     when(rpm.getQueueStorage()).thenReturn(queueStorage);
     when(rpm.getReplicationLogCleanerBarrier()).thenReturn(new ReplicationLogCleanerBarrier());
     when(rpm.listPeers(null)).thenReturn(new ArrayList<>());
@@ -314,4 +318,24 @@ public ZKWatcher getZooKeeper() {
       return null;
     }
   }
+
+  private static class FSTableDescriptorsTest extends FSTableDescriptors {
+    private TableName replicationQueueTableName;
+
+    public FSTableDescriptorsTest(final Configuration conf) throws IOException {
+      super(conf);
+      replicationQueueTableName =
+        TableName.valueOf(conf.get(ReplicationStorageFactory.REPLICATION_QUEUE_TABLE_NAME,
+          ReplicationStorageFactory.REPLICATION_QUEUE_TABLE_NAME_DEFAULT.getNameAsString()));
+    }
+
+    @Override
+    public boolean exists(TableName tablename) throws IOException {
+      if (tablename.equals(replicationQueueTableName)) {
+        return true;
+      } else {
+        return super.exists(tablename);
+      }
+    }
+  }
 }