[
https://issues.apache.org/jira/browse/HBASE-26307?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17422098#comment-17422098
]
Duo Zhang commented on HBASE-26307:
-----------------------------------
Have tried to upgrade to newer version of HBase? 1.2.x has already been EOL.
Thanks.
> 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
> Priority: Major
>
> 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)
