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)
