[HBASE-4501] [replication] Shutting down a stream leaves recovered sources running

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 0.90.4
• Fix Version/s: 0.90.5
• Hadoop Flags: Reviewed
• Assignee: Jean-Daniel Cryans
• Reporter: Jean-Daniel Cryans
• Created: 27/Sep/11 23:13
• Updated: 20/Nov/15 11:54
• Resolved: 05/Oct/11 17:38

Description

When removing a peer it will call ReplicationSourceManager.removePeer which calls closeRecoveredQueue which does this:

LOG.info("Done with the recovered queue " + src.getPeerClusterZnode());
this.oldsources.remove(src);
this.zkHelper.deleteSource(src.getPeerClusterZnode(), false);

This works in the case where the recovered source is done and is calling this method, but when removing a peer it never calls terminate on thus it leaving it running.