Repository: hbase Updated Branches: refs/heads/master bb28a3b46 -> a4afa38f7
HBASE-18788 NPE when running TestSerialReplication (Fabrice Monnier) Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/a4afa38f Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/a4afa38f Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/a4afa38f Branch: refs/heads/master Commit: a4afa38f7a56aa6c36ee1af21fac8ce6d056a3db Parents: bb28a3b Author: Michael Stack <[email protected]> Authored: Sun Oct 8 17:03:39 2017 -0700 Committer: Michael Stack <[email protected]> Committed: Sun Oct 8 17:03:39 2017 -0700 ---------------------------------------------------------------------- .../hadoop/hbase/master/cleaner/ReplicationMetaCleaner.java | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hbase/blob/a4afa38f/hbase-server/src/main/java/org/apache/hadoop/hbase/master/cleaner/ReplicationMetaCleaner.java ---------------------------------------------------------------------- diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/cleaner/ReplicationMetaCleaner.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/cleaner/ReplicationMetaCleaner.java index 3f2dab3..23e5a66 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/cleaner/ReplicationMetaCleaner.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/cleaner/ReplicationMetaCleaner.java @@ -83,8 +83,12 @@ public class ReplicationMetaCleaner extends ScheduledChore { List<ReplicationPeerDescription> peers = admin.listReplicationPeers(); for (ReplicationPeerDescription peerDesc : peers) { - for (Map.Entry<TableName, List<String>> map : peerDesc.getPeerConfig().getTableCFsMap() - .entrySet()) { + Map<TableName, List<String>> tableCFsMap = peerDesc.getPeerConfig().getTableCFsMap(); + if (tableCFsMap ==null) { + continue; + } + + for (Map.Entry<TableName, List<String>> map : tableCFsMap.entrySet()) { if (serialTables.containsKey(map.getKey().getNameAsString())) { serialTables.get(map.getKey().getNameAsString()).add(peerDesc.getPeerId()); break;
