[jira] [Resolved] (HBASE-29116) recoveredSource can not close thread

["selina.yan (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/HBASE-29116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

selina.yan resolved HBASE-29116.
--------------------------------
    Resolution: Pending Closed

> recoveredSource can not close thread
> ------------------------------------
>
>                 Key: HBASE-29116
>                 URL: https://issues.apache.org/jira/browse/HBASE-29116
>             Project: HBase
>          Issue Type: Bug
>    Affects Versions: 2.4.18
>            Reporter: selina.yan
>            Priority: Minor
>
> when the server crash down, old source will be closed, recovered source will start.when replicate completed,we should terminate the source and remove from oldsources ,is that？
> {code:java}
>   /**
>    * Clear the metrics and related replication queue of the specified old source
>    * @param src source to clear
>    */
>   private boolean removeRecoveredSource(ReplicationSourceInterface src) {
>     if (!this.oldsources.remove(src)) {
>       return false;
>     }
>     LOG.info("Done with the recovered queue {}", src.getQueueId());
>     // Delete queue from storage and memory
>     deleteQueue(src.getQueueId());
>     this.walsByIdRecoveredQueues.remove(src.getQueueId());
>     return true;
>   } {code}



--
This message was sent by Atlassian Jira
(v8.20.10#820010)