Duo Zhang created HBASE-29690:
---------------------------------
Summary: Fix typo in TableReplicationQueueStorage.removeAllQueues
Key: HBASE-29690
URL: https://issues.apache.org/jira/browse/HBASE-29690
Project: HBase
Issue Type: Bug
Components: Replication
Reporter: Duo Zhang
{code}
@Override
public void removeAllQueues(String peerId) throws ReplicationException {
Scan scan = new
Scan().setStartStopRowForPrefixScan(ReplicationQueueId.getScanPrefix(peerId))
.addFamily(QUEUE_FAMILY).setFilter(new KeyOnlyFilter());
try (Table table = conn.getTable(tableName); ResultScanner scanner =
table.getScanner(scan)) {
for (;;) {
Result result = scanner.next();
if (result == null) {
break;
}
table.delete(new Delete(result.getRow()));
}
} catch (IOException e) {
throw new ReplicationException("failed to listAllQueueIds, peerId=" +
peerId, e);
}
}
{code}
The message in the exception message should be `removeAllQueues` instead of
`listAllQueueIds`.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
