Apache/hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-2989 [replication] RSM won't cleanup after locking if 0 peers

Browse Source 
git-svn-id: https://svn.apache.org/repos/asf/hbase/trunk@1001014 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Jean-Daniel Cryans 2010-09-24 18:32:26 +00:00
parent 4163b90a87
commit da611388b4
2 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
CHANGES.txt
View File

@ -538,6 +538,7 @@ Release 0.21.0 - Unreleased
HBASE-3003 ClassSize constants dont use 'final' HBASE-3003 ClassSize constants dont use 'final'
HBASE-3002 Fix zookeepers.sh to work properly with strange JVM options HBASE-3002 Fix zookeepers.sh to work properly with strange JVM options
HBASE-3028 No basescanner means no GC'ing of split, offlined parent regions HBASE-3028 No basescanner means no GC'ing of split, offlined parent regions
HBASE-2989 [replication] RSM won't cleanup after locking if 0 peers
IMPROVEMENTS IMPROVEMENTS
HBASE-1760 Cleanup TODOs in HTable HBASE-1760 Cleanup TODOs in HTable

2
src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.java
View File

@ -285,10 +285,10 @@ public class ReplicationSourceManager {
LOG.info("Moving " + rsZnode + "'s hlogs to my queue"); LOG.info("Moving " + rsZnode + "'s hlogs to my queue");
SortedMap<String, SortedSet<String>> newQueues = SortedMap<String, SortedSet<String>> newQueues =
this.zkHelper.copyQueuesFromRS(rsZnode); this.zkHelper.copyQueuesFromRS(rsZnode);
this.zkHelper.deleteRsQueues(rsZnode);
if (newQueues == null || newQueues.size() == 0) { if (newQueues == null || newQueues.size() == 0) {
return; return;
} }
this.zkHelper.deleteRsQueues(rsZnode);
for (Map.Entry<String, SortedSet<String>> entry : newQueues.entrySet()) { for (Map.Entry<String, SortedSet<String>> entry : newQueues.entrySet()) {
String peerId = entry.getKey(); String peerId = entry.getKey();