From 1d704a79ab8942b5092640d7274826fd4d31c01d Mon Sep 17 00:00:00 2001 From: Duo Zhang Date: Tue, 11 Jul 2023 21:40:50 +0800 Subject: [PATCH] HBASE-27969 TableReplicationQueueStorage.hasData does not work as expected (#5321) Signed-off-by: Liangjun He --- .../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 e59edd52f793..8fff3d461f74 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 Set getAllHFileRefs() throws ReplicationException { @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); }