[jira] [Created] (HBASE-29690) Fix typo in TableReplicationQueueStorage.removeAllQueues

["Duo Zhang (Jira)" <ji...@apache.org>]

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)