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)