[jira] [Created] (HBASE-26307) Recovered ReplicationSource not terminated

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

zju_zsx created HBASE-26307:
-------------------------------

             Summary: Recovered ReplicationSource not terminated
                 Key: HBASE-26307
                 URL: https://issues.apache.org/jira/browse/HBASE-26307
             Project: HBase
          Issue Type: Bug
          Components: Replication
    Affects Versions: 1.2.6
            Reporter: zju_zsx


Recovered ReplicationSource not terminated after replicated all wal.

after all task done, it just remove source，but does not terminate it. so some resources(such as zk connection)  in replication endpoint leaks.
{code:java}
//代码占位符
if (replicationQueueInfo.isQueueRecovered()) {
  // use synchronize to make sure one last thread will clean the queue
  synchronized (workerThreads) {
    Threads.sleep(100);// wait a short while for other worker thread to fully exit
    boolean allOtherTaskDone = true;
    for (ReplicationSourceWorkerThread worker : workerThreads.values()) {
      if (!worker.equals(this) && worker.isAlive()) {
        allOtherTaskDone = false;
        break;
      }
    }
    if (allOtherTaskDone) {
      manager.closeRecoveredQueue(this.source);
      LOG.info("Finished recovering queue " + peerClusterZnode
          + " with the following stats: " + getStats());
    }
  }
}{code}



--
This message was sent by Atlassian Jira
(v8.3.4#803005)