diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/AssignmentManager.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/AssignmentManager.java index 2ffe466..8cce0fd 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/AssignmentManager.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/AssignmentManager.java @@ -1657,9 +1657,19 @@ public class AssignmentManager { List regionsNotRecordedInMeta = new ArrayList(); for (HRegionInfo hri : regionsRecordedInMeta) { TableName table = hri.getTable(); - HTableDescriptor htd = master.getTableDescriptors().get(table); // look at the HTD for the replica count. That's the source of truth - int desiredRegionReplication = htd.getRegionReplication(); + int desiredRegionReplication = 1; + try { + HTableDescriptor htd = master.getTableDescriptors().get(table); + if (htd == null) { + LOG.warn("master can not get TableDescriptor from table '" + table); + } else { + desiredRegionReplication = htd.getRegionReplication(); + } + } catch (IOException e){ + LOG.warn("Couldn't get the replication attribute of the table " + table + " due to " + + e.getMessage()); + } for (int i = 0; i < desiredRegionReplication; i++) { HRegionInfo replica = RegionReplicaUtil.getRegionInfoForReplica(hri, i); if (regionsRecordedInMeta.contains(replica)) continue; @@ -1702,8 +1712,18 @@ public class AssignmentManager { // maybe because it crashed. PairOfSameType p = MetaTableAccessor.getMergeRegions(result); if (p.getFirst() != null && p.getSecond() != null) { - int numReplicas = ((MasterServices)server).getTableDescriptors().get(p.getFirst(). - getTable()).getRegionReplication(); + int numReplicas = 1; + try { + HTableDescriptor htd = ((MasterServices)server).getTableDescriptors().get(p.getFirst().getTable()); + if (htd == null) { + LOG.warn("Can not get TableDescriptors from table " + p.getFirst().getTable()); + } else { + numReplicas = htd.getRegionReplication(); + } + } catch (Exception e) { + LOG.warn("Couldn't get the replication attribute of the table " + p.getFirst(). + getTable() + " due to " + e.getMessage()); + } for (HRegionInfo merge : p) { for (int i = 1; i < numReplicas; i++) { replicasToClose.add(RegionReplicaUtil.getRegionInfoForReplica(merge, i)); @@ -2647,8 +2667,12 @@ public class AssignmentManager { } int numReplicas = 1; try { - numReplicas = ((MasterServices)server).getTableDescriptors().get(mergedHri.getTable()). - getRegionReplication(); + HTableDescriptor htd = ((MasterServices)server).getTableDescriptors().get(mergedHri.getTable()); + if(htd == null) { + LOG.warn("Can not get TableDescriptors from table " + mergedHri.getTable()); + } else { + numReplicas = htd.getRegionReplication(); + } } catch (IOException e) { LOG.warn("Couldn't get the replication attribute of the table " + mergedHri.getTable() + " due to " + e.getMessage() + ". The assignment of replicas for the merged region " + @@ -2676,8 +2700,13 @@ public class AssignmentManager { // the replica1s of daughters will be on the same machine int numReplicas = 1; try { - numReplicas = ((MasterServices)server).getTableDescriptors().get(parentHri.getTable()). - getRegionReplication(); + HTableDescriptor htd = ((MasterServices)server).getTableDescriptors().get(parentHri.getTable()); + if(htd == null) { + LOG.warn("Can not get TableDescriptors from table " + parentHri.getTable()); + } + else { + numReplicas = htd.getRegionReplication(); + } } catch (IOException e) { LOG.warn("Couldn't get the replication attribute of the table " + parentHri.getTable() + " due to " + e.getMessage() + ". The assignment of daughter replicas " +