HBASE-20585 Need to clear peer map when clearing MasterProcedureScheduler

2018-05-15 21:24:13 +08:00 · 2018-05-15 21:24:13 +08:00 · 82e3011166
parent 60b8344cf1
commit 82e3011166
1 changed files with 4 additions and 0 deletions
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/procedure/MasterProcedureScheduler.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/procedure/MasterProcedureScheduler.java
@ -247,6 +247,10 @@ public class MasterProcedureScheduler extends AbstractProcedureScheduler {
    clear(tableMap, tableRunQueue, TABLE_QUEUE_KEY_COMPARATOR);
    tableMap = null;

+    // Remove Peers
+    clear(peerMap, peerRunQueue, PEER_QUEUE_KEY_COMPARATOR);
+    peerMap = null;
+
    assert size() == 0 : "expected queue size to be 0, got " + size();
  }