From ac36c7520405c33f74d0612f2ba6bdfe1bd11e7d Mon Sep 17 00:00:00 2001 From: Duo Zhang Date: Mon, 10 Jul 2023 22:58:36 +0800 Subject: [PATCH] HBASE-27969 TableReplicationQueueStorage.hasData does not work as expected --- .../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); }