This is an automated email from the ASF dual-hosted git repository.

zhangduo pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hbase.git


The following commit(s) were added to refs/heads/master by this push:
     new 1d704a79ab8 HBASE-27969 TableReplicationQueueStorage.hasData does not 
work as expected (#5321)
1d704a79ab8 is described below

commit 1d704a79ab8942b5092640d7274826fd4d31c01d
Author: Duo Zhang <zhang...@apache.org>
AuthorDate: Tue Jul 11 21:40:50 2023 +0800

    HBASE-27969 TableReplicationQueueStorage.hasData does not work as expected 
(#5321)
    
    Signed-off-by: Liangjun He <heliang...@apache.org>
---
 .../apache/hadoop/hbase/replication/TableReplicationQueueStorage.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/hbase-replication/src/main/java/org/apache/hadoop/hbase/replication/TableReplicationQueueStorage.java
 
b/hbase-replication/src/main/java/org/apache/hadoop/hbase/replication/TableReplicationQueueStorage.java
index e59edd52f79..8fff3d461f7 100644
--- 
a/hbase-replication/src/main/java/org/apache/hadoop/hbase/replication/TableReplicationQueueStorage.java
+++ 
b/hbase-replication/src/main/java/org/apache/hadoop/hbase/replication/TableReplicationQueueStorage.java
@@ -533,7 +533,7 @@ public class TableReplicationQueueStorage implements 
ReplicationQueueStorage {
   @Override
   public boolean hasData() throws ReplicationException {
     try {
-      return conn.getAdmin().getDescriptor(tableName) != null;
+      return conn.getAdmin().tableExists(tableName);
     } catch (IOException e) {
       throw new ReplicationException("failed to get replication queue table", 
e);
     }

Reply via email to