This is an automated email from the ASF dual-hosted git repository. zhangduo pushed a commit to branch branch-3 in repository https://gitbox.apache.org/repos/asf/hbase.git
The following commit(s) were added to refs/heads/branch-3 by this push: new cb0540cf918 HBASE-27969 TableReplicationQueueStorage.hasData does not work as expected (#5321) cb0540cf918 is described below commit cb0540cf91823f130efc40d7384b1679c64cce7d 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> (cherry picked from commit 1d704a79ab8942b5092640d7274826fd4d31c01d) --- .../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); }