You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by gi...@apache.org on 2018/09/18 14:52:19 UTC
[09/18] hbase-site git commit: Published site at
cebb725a9f4ab8dd9d3f306d21d53d6f56161c51.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/ab597584/devapidocs/src-html/org/apache/hadoop/hbase/master/balancer/BaseLoadBalancer.Cluster.AssignRegionAction.html
----------------------------------------------------------------------
diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/master/balancer/BaseLoadBalancer.Cluster.AssignRegionAction.html b/devapidocs/src-html/org/apache/hadoop/hbase/master/balancer/BaseLoadBalancer.Cluster.AssignRegionAction.html
index d974429..e478f39 100644
--- a/devapidocs/src-html/org/apache/hadoop/hbase/master/balancer/BaseLoadBalancer.Cluster.AssignRegionAction.html
+++ b/devapidocs/src-html/org/apache/hadoop/hbase/master/balancer/BaseLoadBalancer.Cluster.AssignRegionAction.html
@@ -42,32 +42,32 @@
<span class="sourceLineNo">034</span>import java.util.TreeMap;<a name="line.34"></a>
<span class="sourceLineNo">035</span>import java.util.function.Predicate;<a name="line.35"></a>
<span class="sourceLineNo">036</span>import java.util.stream.Collectors;<a name="line.36"></a>
-<span class="sourceLineNo">037</span>import org.apache.commons.lang3.NotImplementedException;<a name="line.37"></a>
-<span class="sourceLineNo">038</span>import org.apache.hadoop.conf.Configuration;<a name="line.38"></a>
-<span class="sourceLineNo">039</span>import org.apache.hadoop.hbase.ClusterMetrics;<a name="line.39"></a>
-<span class="sourceLineNo">040</span>import org.apache.hadoop.hbase.HBaseConfiguration;<a name="line.40"></a>
-<span class="sourceLineNo">041</span>import org.apache.hadoop.hbase.HBaseIOException;<a name="line.41"></a>
-<span class="sourceLineNo">042</span>import org.apache.hadoop.hbase.HConstants;<a name="line.42"></a>
-<span class="sourceLineNo">043</span>import org.apache.hadoop.hbase.HDFSBlocksDistribution;<a name="line.43"></a>
-<span class="sourceLineNo">044</span>import org.apache.hadoop.hbase.ServerMetrics;<a name="line.44"></a>
-<span class="sourceLineNo">045</span>import org.apache.hadoop.hbase.ServerName;<a name="line.45"></a>
-<span class="sourceLineNo">046</span>import org.apache.hadoop.hbase.TableName;<a name="line.46"></a>
-<span class="sourceLineNo">047</span>import org.apache.hadoop.hbase.client.RegionInfo;<a name="line.47"></a>
-<span class="sourceLineNo">048</span>import org.apache.hadoop.hbase.client.RegionReplicaUtil;<a name="line.48"></a>
-<span class="sourceLineNo">049</span>import org.apache.hadoop.hbase.master.LoadBalancer;<a name="line.49"></a>
-<span class="sourceLineNo">050</span>import org.apache.hadoop.hbase.master.MasterServices;<a name="line.50"></a>
-<span class="sourceLineNo">051</span>import org.apache.hadoop.hbase.master.RackManager;<a name="line.51"></a>
-<span class="sourceLineNo">052</span>import org.apache.hadoop.hbase.master.RegionPlan;<a name="line.52"></a>
-<span class="sourceLineNo">053</span>import org.apache.hadoop.hbase.master.balancer.BaseLoadBalancer.Cluster.Action.Type;<a name="line.53"></a>
-<span class="sourceLineNo">054</span>import org.apache.yetus.audience.InterfaceAudience;<a name="line.54"></a>
-<span class="sourceLineNo">055</span>import org.slf4j.Logger;<a name="line.55"></a>
-<span class="sourceLineNo">056</span>import org.slf4j.LoggerFactory;<a name="line.56"></a>
-<span class="sourceLineNo">057</span><a name="line.57"></a>
-<span class="sourceLineNo">058</span>import org.apache.hbase.thirdparty.com.google.common.annotations.VisibleForTesting;<a name="line.58"></a>
-<span class="sourceLineNo">059</span>import org.apache.hbase.thirdparty.com.google.common.base.Joiner;<a name="line.59"></a>
-<span class="sourceLineNo">060</span>import org.apache.hbase.thirdparty.com.google.common.collect.ArrayListMultimap;<a name="line.60"></a>
-<span class="sourceLineNo">061</span>import org.apache.hbase.thirdparty.com.google.common.collect.Lists;<a name="line.61"></a>
-<span class="sourceLineNo">062</span>import org.apache.hbase.thirdparty.com.google.common.collect.Sets;<a name="line.62"></a>
+<span class="sourceLineNo">037</span><a name="line.37"></a>
+<span class="sourceLineNo">038</span>import org.apache.commons.lang3.NotImplementedException;<a name="line.38"></a>
+<span class="sourceLineNo">039</span>import org.apache.hadoop.conf.Configuration;<a name="line.39"></a>
+<span class="sourceLineNo">040</span>import org.apache.hadoop.hbase.ClusterMetrics;<a name="line.40"></a>
+<span class="sourceLineNo">041</span>import org.apache.hadoop.hbase.HBaseConfiguration;<a name="line.41"></a>
+<span class="sourceLineNo">042</span>import org.apache.hadoop.hbase.HBaseIOException;<a name="line.42"></a>
+<span class="sourceLineNo">043</span>import org.apache.hadoop.hbase.HConstants;<a name="line.43"></a>
+<span class="sourceLineNo">044</span>import org.apache.hadoop.hbase.HDFSBlocksDistribution;<a name="line.44"></a>
+<span class="sourceLineNo">045</span>import org.apache.hadoop.hbase.ServerMetrics;<a name="line.45"></a>
+<span class="sourceLineNo">046</span>import org.apache.hadoop.hbase.ServerName;<a name="line.46"></a>
+<span class="sourceLineNo">047</span>import org.apache.hadoop.hbase.TableName;<a name="line.47"></a>
+<span class="sourceLineNo">048</span>import org.apache.hadoop.hbase.client.RegionInfo;<a name="line.48"></a>
+<span class="sourceLineNo">049</span>import org.apache.hadoop.hbase.client.RegionReplicaUtil;<a name="line.49"></a>
+<span class="sourceLineNo">050</span>import org.apache.hadoop.hbase.master.LoadBalancer;<a name="line.50"></a>
+<span class="sourceLineNo">051</span>import org.apache.hadoop.hbase.master.MasterServices;<a name="line.51"></a>
+<span class="sourceLineNo">052</span>import org.apache.hadoop.hbase.master.RackManager;<a name="line.52"></a>
+<span class="sourceLineNo">053</span>import org.apache.hadoop.hbase.master.RegionPlan;<a name="line.53"></a>
+<span class="sourceLineNo">054</span>import org.apache.hadoop.hbase.master.balancer.BaseLoadBalancer.Cluster.Action.Type;<a name="line.54"></a>
+<span class="sourceLineNo">055</span>import org.apache.hbase.thirdparty.com.google.common.annotations.VisibleForTesting;<a name="line.55"></a>
+<span class="sourceLineNo">056</span>import org.apache.hbase.thirdparty.com.google.common.base.Joiner;<a name="line.56"></a>
+<span class="sourceLineNo">057</span>import org.apache.hbase.thirdparty.com.google.common.collect.ArrayListMultimap;<a name="line.57"></a>
+<span class="sourceLineNo">058</span>import org.apache.hbase.thirdparty.com.google.common.collect.Lists;<a name="line.58"></a>
+<span class="sourceLineNo">059</span>import org.apache.hbase.thirdparty.com.google.common.collect.Sets;<a name="line.59"></a>
+<span class="sourceLineNo">060</span>import org.apache.yetus.audience.InterfaceAudience;<a name="line.60"></a>
+<span class="sourceLineNo">061</span>import org.slf4j.Logger;<a name="line.61"></a>
+<span class="sourceLineNo">062</span>import org.slf4j.LoggerFactory;<a name="line.62"></a>
<span class="sourceLineNo">063</span><a name="line.63"></a>
<span class="sourceLineNo">064</span>/**<a name="line.64"></a>
<span class="sourceLineNo">065</span> * The base class for load balancers. It provides the the functions used to by<a name="line.65"></a>
@@ -1462,181 +1462,186 @@
<span class="sourceLineNo">1454</span> for (Map.Entry<RegionInfo, ServerName> entry : regions.entrySet()) {<a name="line.1454"></a>
<span class="sourceLineNo">1455</span> RegionInfo region = entry.getKey();<a name="line.1455"></a>
<span class="sourceLineNo">1456</span> ServerName oldServerName = entry.getValue();<a name="line.1456"></a>
-<span class="sourceLineNo">1457</span> if (!hasRegionReplica && !RegionReplicaUtil.isDefaultReplica(region)) {<a name="line.1457"></a>
-<span class="sourceLineNo">1458</span> hasRegionReplica = true;<a name="line.1458"></a>
-<span class="sourceLineNo">1459</span> }<a name="line.1459"></a>
-<span class="sourceLineNo">1460</span> List<ServerName> localServers = new ArrayList<>();<a name="line.1460"></a>
-<span class="sourceLineNo">1461</span> if (oldServerName != null) {<a name="line.1461"></a>
-<span class="sourceLineNo">1462</span> localServers = serversByHostname.get(oldServerName.getHostnameLowerCase());<a name="line.1462"></a>
-<span class="sourceLineNo">1463</span> }<a name="line.1463"></a>
-<span class="sourceLineNo">1464</span> if (localServers.isEmpty()) {<a name="line.1464"></a>
-<span class="sourceLineNo">1465</span> // No servers on the new cluster match up with this hostname, assign randomly, later.<a name="line.1465"></a>
-<span class="sourceLineNo">1466</span> randomAssignRegions.add(region);<a name="line.1466"></a>
-<span class="sourceLineNo">1467</span> if (oldServerName != null) {<a name="line.1467"></a>
-<span class="sourceLineNo">1468</span> oldHostsNoLongerPresent.add(oldServerName.getHostnameLowerCase());<a name="line.1468"></a>
-<span class="sourceLineNo">1469</span> }<a name="line.1469"></a>
-<span class="sourceLineNo">1470</span> } else if (localServers.size() == 1) {<a name="line.1470"></a>
-<span class="sourceLineNo">1471</span> // the usual case - one new server on same host<a name="line.1471"></a>
-<span class="sourceLineNo">1472</span> ServerName target = localServers.get(0);<a name="line.1472"></a>
-<span class="sourceLineNo">1473</span> assignments.get(target).add(region);<a name="line.1473"></a>
-<span class="sourceLineNo">1474</span> numRetainedAssigments++;<a name="line.1474"></a>
-<span class="sourceLineNo">1475</span> } else {<a name="line.1475"></a>
-<span class="sourceLineNo">1476</span> // multiple new servers in the cluster on this same host<a name="line.1476"></a>
-<span class="sourceLineNo">1477</span> if (localServers.contains(oldServerName)) {<a name="line.1477"></a>
-<span class="sourceLineNo">1478</span> assignments.get(oldServerName).add(region);<a name="line.1478"></a>
-<span class="sourceLineNo">1479</span> numRetainedAssigments++;<a name="line.1479"></a>
-<span class="sourceLineNo">1480</span> } else {<a name="line.1480"></a>
-<span class="sourceLineNo">1481</span> ServerName target = null;<a name="line.1481"></a>
-<span class="sourceLineNo">1482</span> for (ServerName tmp : localServers) {<a name="line.1482"></a>
-<span class="sourceLineNo">1483</span> if (tmp.getPort() == oldServerName.getPort()) {<a name="line.1483"></a>
-<span class="sourceLineNo">1484</span> target = tmp;<a name="line.1484"></a>
-<span class="sourceLineNo">1485</span> assignments.get(tmp).add(region);<a name="line.1485"></a>
-<span class="sourceLineNo">1486</span> numRetainedAssigments++;<a name="line.1486"></a>
-<span class="sourceLineNo">1487</span> break;<a name="line.1487"></a>
-<span class="sourceLineNo">1488</span> }<a name="line.1488"></a>
-<span class="sourceLineNo">1489</span> }<a name="line.1489"></a>
-<span class="sourceLineNo">1490</span> if (target == null) {<a name="line.1490"></a>
-<span class="sourceLineNo">1491</span> randomAssignRegions.add(region);<a name="line.1491"></a>
-<span class="sourceLineNo">1492</span> }<a name="line.1492"></a>
-<span class="sourceLineNo">1493</span> }<a name="line.1493"></a>
-<span class="sourceLineNo">1494</span> }<a name="line.1494"></a>
-<span class="sourceLineNo">1495</span> }<a name="line.1495"></a>
-<span class="sourceLineNo">1496</span><a name="line.1496"></a>
-<span class="sourceLineNo">1497</span> // If servers from prior assignment aren't present, then lets do randomAssignment on regions.<a name="line.1497"></a>
-<span class="sourceLineNo">1498</span> if (randomAssignRegions.size() > 0) {<a name="line.1498"></a>
-<span class="sourceLineNo">1499</span> Cluster cluster = createCluster(servers, regions.keySet(), hasRegionReplica);<a name="line.1499"></a>
-<span class="sourceLineNo">1500</span> for (Map.Entry<ServerName, List<RegionInfo>> entry : assignments.entrySet()) {<a name="line.1500"></a>
-<span class="sourceLineNo">1501</span> ServerName sn = entry.getKey();<a name="line.1501"></a>
-<span class="sourceLineNo">1502</span> for (RegionInfo region : entry.getValue()) {<a name="line.1502"></a>
-<span class="sourceLineNo">1503</span> cluster.doAssignRegion(region, sn);<a name="line.1503"></a>
-<span class="sourceLineNo">1504</span> }<a name="line.1504"></a>
-<span class="sourceLineNo">1505</span> }<a name="line.1505"></a>
-<span class="sourceLineNo">1506</span> for (RegionInfo region : randomAssignRegions) {<a name="line.1506"></a>
-<span class="sourceLineNo">1507</span> ServerName target = randomAssignment(cluster, region, servers);<a name="line.1507"></a>
-<span class="sourceLineNo">1508</span> assignments.get(target).add(region);<a name="line.1508"></a>
-<span class="sourceLineNo">1509</span> numRandomAssignments++;<a name="line.1509"></a>
+<span class="sourceLineNo">1457</span> // In the current set of regions even if one has region replica let us go with<a name="line.1457"></a>
+<span class="sourceLineNo">1458</span> // getting the entire snapshot<a name="line.1458"></a>
+<span class="sourceLineNo">1459</span> if (this.services != null && this.services.getAssignmentManager() != null) { // for tests<a name="line.1459"></a>
+<span class="sourceLineNo">1460</span> if (!hasRegionReplica && this.services.getAssignmentManager().getRegionStates()<a name="line.1460"></a>
+<span class="sourceLineNo">1461</span> .isReplicaAvailableForRegion(region)) {<a name="line.1461"></a>
+<span class="sourceLineNo">1462</span> hasRegionReplica = true;<a name="line.1462"></a>
+<span class="sourceLineNo">1463</span> }<a name="line.1463"></a>
+<span class="sourceLineNo">1464</span> }<a name="line.1464"></a>
+<span class="sourceLineNo">1465</span> List<ServerName> localServers = new ArrayList<>();<a name="line.1465"></a>
+<span class="sourceLineNo">1466</span> if (oldServerName != null) {<a name="line.1466"></a>
+<span class="sourceLineNo">1467</span> localServers = serversByHostname.get(oldServerName.getHostnameLowerCase());<a name="line.1467"></a>
+<span class="sourceLineNo">1468</span> }<a name="line.1468"></a>
+<span class="sourceLineNo">1469</span> if (localServers.isEmpty()) {<a name="line.1469"></a>
+<span class="sourceLineNo">1470</span> // No servers on the new cluster match up with this hostname, assign randomly, later.<a name="line.1470"></a>
+<span class="sourceLineNo">1471</span> randomAssignRegions.add(region);<a name="line.1471"></a>
+<span class="sourceLineNo">1472</span> if (oldServerName != null) {<a name="line.1472"></a>
+<span class="sourceLineNo">1473</span> oldHostsNoLongerPresent.add(oldServerName.getHostnameLowerCase());<a name="line.1473"></a>
+<span class="sourceLineNo">1474</span> }<a name="line.1474"></a>
+<span class="sourceLineNo">1475</span> } else if (localServers.size() == 1) {<a name="line.1475"></a>
+<span class="sourceLineNo">1476</span> // the usual case - one new server on same host<a name="line.1476"></a>
+<span class="sourceLineNo">1477</span> ServerName target = localServers.get(0);<a name="line.1477"></a>
+<span class="sourceLineNo">1478</span> assignments.get(target).add(region);<a name="line.1478"></a>
+<span class="sourceLineNo">1479</span> numRetainedAssigments++;<a name="line.1479"></a>
+<span class="sourceLineNo">1480</span> } else {<a name="line.1480"></a>
+<span class="sourceLineNo">1481</span> // multiple new servers in the cluster on this same host<a name="line.1481"></a>
+<span class="sourceLineNo">1482</span> if (localServers.contains(oldServerName)) {<a name="line.1482"></a>
+<span class="sourceLineNo">1483</span> assignments.get(oldServerName).add(region);<a name="line.1483"></a>
+<span class="sourceLineNo">1484</span> numRetainedAssigments++;<a name="line.1484"></a>
+<span class="sourceLineNo">1485</span> } else {<a name="line.1485"></a>
+<span class="sourceLineNo">1486</span> ServerName target = null;<a name="line.1486"></a>
+<span class="sourceLineNo">1487</span> for (ServerName tmp : localServers) {<a name="line.1487"></a>
+<span class="sourceLineNo">1488</span> if (tmp.getPort() == oldServerName.getPort()) {<a name="line.1488"></a>
+<span class="sourceLineNo">1489</span> target = tmp;<a name="line.1489"></a>
+<span class="sourceLineNo">1490</span> assignments.get(tmp).add(region);<a name="line.1490"></a>
+<span class="sourceLineNo">1491</span> numRetainedAssigments++;<a name="line.1491"></a>
+<span class="sourceLineNo">1492</span> break;<a name="line.1492"></a>
+<span class="sourceLineNo">1493</span> }<a name="line.1493"></a>
+<span class="sourceLineNo">1494</span> }<a name="line.1494"></a>
+<span class="sourceLineNo">1495</span> if (target == null) {<a name="line.1495"></a>
+<span class="sourceLineNo">1496</span> randomAssignRegions.add(region);<a name="line.1496"></a>
+<span class="sourceLineNo">1497</span> }<a name="line.1497"></a>
+<span class="sourceLineNo">1498</span> }<a name="line.1498"></a>
+<span class="sourceLineNo">1499</span> }<a name="line.1499"></a>
+<span class="sourceLineNo">1500</span> }<a name="line.1500"></a>
+<span class="sourceLineNo">1501</span><a name="line.1501"></a>
+<span class="sourceLineNo">1502</span> // If servers from prior assignment aren't present, then lets do randomAssignment on regions.<a name="line.1502"></a>
+<span class="sourceLineNo">1503</span> if (randomAssignRegions.size() > 0) {<a name="line.1503"></a>
+<span class="sourceLineNo">1504</span> Cluster cluster = createCluster(servers, regions.keySet(), hasRegionReplica);<a name="line.1504"></a>
+<span class="sourceLineNo">1505</span> for (Map.Entry<ServerName, List<RegionInfo>> entry : assignments.entrySet()) {<a name="line.1505"></a>
+<span class="sourceLineNo">1506</span> ServerName sn = entry.getKey();<a name="line.1506"></a>
+<span class="sourceLineNo">1507</span> for (RegionInfo region : entry.getValue()) {<a name="line.1507"></a>
+<span class="sourceLineNo">1508</span> cluster.doAssignRegion(region, sn);<a name="line.1508"></a>
+<span class="sourceLineNo">1509</span> }<a name="line.1509"></a>
<span class="sourceLineNo">1510</span> }<a name="line.1510"></a>
-<span class="sourceLineNo">1511</span> }<a name="line.1511"></a>
-<span class="sourceLineNo">1512</span><a name="line.1512"></a>
-<span class="sourceLineNo">1513</span> String randomAssignMsg = "";<a name="line.1513"></a>
-<span class="sourceLineNo">1514</span> if (numRandomAssignments > 0) {<a name="line.1514"></a>
-<span class="sourceLineNo">1515</span> randomAssignMsg =<a name="line.1515"></a>
-<span class="sourceLineNo">1516</span> numRandomAssignments + " regions were assigned "<a name="line.1516"></a>
-<span class="sourceLineNo">1517</span> + "to random hosts, since the old hosts for these regions are no "<a name="line.1517"></a>
-<span class="sourceLineNo">1518</span> + "longer present in the cluster. These hosts were:\n "<a name="line.1518"></a>
-<span class="sourceLineNo">1519</span> + Joiner.on("\n ").join(oldHostsNoLongerPresent);<a name="line.1519"></a>
-<span class="sourceLineNo">1520</span> }<a name="line.1520"></a>
-<span class="sourceLineNo">1521</span><a name="line.1521"></a>
-<span class="sourceLineNo">1522</span> LOG.info("Reassigned " + regions.size() + " regions. " + numRetainedAssigments<a name="line.1522"></a>
-<span class="sourceLineNo">1523</span> + " retained the pre-restart assignment. " + randomAssignMsg);<a name="line.1523"></a>
-<span class="sourceLineNo">1524</span> return assignments;<a name="line.1524"></a>
-<span class="sourceLineNo">1525</span> }<a name="line.1525"></a>
+<span class="sourceLineNo">1511</span> for (RegionInfo region : randomAssignRegions) {<a name="line.1511"></a>
+<span class="sourceLineNo">1512</span> ServerName target = randomAssignment(cluster, region, servers);<a name="line.1512"></a>
+<span class="sourceLineNo">1513</span> assignments.get(target).add(region);<a name="line.1513"></a>
+<span class="sourceLineNo">1514</span> numRandomAssignments++;<a name="line.1514"></a>
+<span class="sourceLineNo">1515</span> }<a name="line.1515"></a>
+<span class="sourceLineNo">1516</span> }<a name="line.1516"></a>
+<span class="sourceLineNo">1517</span><a name="line.1517"></a>
+<span class="sourceLineNo">1518</span> String randomAssignMsg = "";<a name="line.1518"></a>
+<span class="sourceLineNo">1519</span> if (numRandomAssignments > 0) {<a name="line.1519"></a>
+<span class="sourceLineNo">1520</span> randomAssignMsg =<a name="line.1520"></a>
+<span class="sourceLineNo">1521</span> numRandomAssignments + " regions were assigned "<a name="line.1521"></a>
+<span class="sourceLineNo">1522</span> + "to random hosts, since the old hosts for these regions are no "<a name="line.1522"></a>
+<span class="sourceLineNo">1523</span> + "longer present in the cluster. These hosts were:\n "<a name="line.1523"></a>
+<span class="sourceLineNo">1524</span> + Joiner.on("\n ").join(oldHostsNoLongerPresent);<a name="line.1524"></a>
+<span class="sourceLineNo">1525</span> }<a name="line.1525"></a>
<span class="sourceLineNo">1526</span><a name="line.1526"></a>
-<span class="sourceLineNo">1527</span> @Override<a name="line.1527"></a>
-<span class="sourceLineNo">1528</span> public void initialize() throws HBaseIOException{<a name="line.1528"></a>
-<span class="sourceLineNo">1529</span> }<a name="line.1529"></a>
-<span class="sourceLineNo">1530</span><a name="line.1530"></a>
-<span class="sourceLineNo">1531</span> @Override<a name="line.1531"></a>
-<span class="sourceLineNo">1532</span> public void regionOnline(RegionInfo regionInfo, ServerName sn) {<a name="line.1532"></a>
-<span class="sourceLineNo">1533</span> }<a name="line.1533"></a>
-<span class="sourceLineNo">1534</span><a name="line.1534"></a>
-<span class="sourceLineNo">1535</span> @Override<a name="line.1535"></a>
-<span class="sourceLineNo">1536</span> public void regionOffline(RegionInfo regionInfo) {<a name="line.1536"></a>
-<span class="sourceLineNo">1537</span> }<a name="line.1537"></a>
-<span class="sourceLineNo">1538</span><a name="line.1538"></a>
-<span class="sourceLineNo">1539</span> @Override<a name="line.1539"></a>
-<span class="sourceLineNo">1540</span> public boolean isStopped() {<a name="line.1540"></a>
-<span class="sourceLineNo">1541</span> return stopped;<a name="line.1541"></a>
+<span class="sourceLineNo">1527</span> LOG.info("Reassigned " + regions.size() + " regions. " + numRetainedAssigments<a name="line.1527"></a>
+<span class="sourceLineNo">1528</span> + " retained the pre-restart assignment. " + randomAssignMsg);<a name="line.1528"></a>
+<span class="sourceLineNo">1529</span> return assignments;<a name="line.1529"></a>
+<span class="sourceLineNo">1530</span> }<a name="line.1530"></a>
+<span class="sourceLineNo">1531</span><a name="line.1531"></a>
+<span class="sourceLineNo">1532</span> @Override<a name="line.1532"></a>
+<span class="sourceLineNo">1533</span> public void initialize() throws HBaseIOException{<a name="line.1533"></a>
+<span class="sourceLineNo">1534</span> }<a name="line.1534"></a>
+<span class="sourceLineNo">1535</span><a name="line.1535"></a>
+<span class="sourceLineNo">1536</span> @Override<a name="line.1536"></a>
+<span class="sourceLineNo">1537</span> public void regionOnline(RegionInfo regionInfo, ServerName sn) {<a name="line.1537"></a>
+<span class="sourceLineNo">1538</span> }<a name="line.1538"></a>
+<span class="sourceLineNo">1539</span><a name="line.1539"></a>
+<span class="sourceLineNo">1540</span> @Override<a name="line.1540"></a>
+<span class="sourceLineNo">1541</span> public void regionOffline(RegionInfo regionInfo) {<a name="line.1541"></a>
<span class="sourceLineNo">1542</span> }<a name="line.1542"></a>
<span class="sourceLineNo">1543</span><a name="line.1543"></a>
<span class="sourceLineNo">1544</span> @Override<a name="line.1544"></a>
-<span class="sourceLineNo">1545</span> public void stop(String why) {<a name="line.1545"></a>
-<span class="sourceLineNo">1546</span> LOG.info("Load Balancer stop requested: "+why);<a name="line.1546"></a>
-<span class="sourceLineNo">1547</span> stopped = true;<a name="line.1547"></a>
-<span class="sourceLineNo">1548</span> }<a name="line.1548"></a>
-<span class="sourceLineNo">1549</span><a name="line.1549"></a>
-<span class="sourceLineNo">1550</span> /**<a name="line.1550"></a>
-<span class="sourceLineNo">1551</span> * Used to assign a single region to a random server.<a name="line.1551"></a>
-<span class="sourceLineNo">1552</span> */<a name="line.1552"></a>
-<span class="sourceLineNo">1553</span> private ServerName randomAssignment(Cluster cluster, RegionInfo regionInfo,<a name="line.1553"></a>
-<span class="sourceLineNo">1554</span> List<ServerName> servers) {<a name="line.1554"></a>
-<span class="sourceLineNo">1555</span> int numServers = servers.size(); // servers is not null, numServers > 1<a name="line.1555"></a>
-<span class="sourceLineNo">1556</span> ServerName sn = null;<a name="line.1556"></a>
-<span class="sourceLineNo">1557</span> final int maxIterations = numServers * 4;<a name="line.1557"></a>
-<span class="sourceLineNo">1558</span> int iterations = 0;<a name="line.1558"></a>
-<span class="sourceLineNo">1559</span> List<ServerName> usedSNs = new ArrayList<>(servers.size());<a name="line.1559"></a>
-<span class="sourceLineNo">1560</span> do {<a name="line.1560"></a>
-<span class="sourceLineNo">1561</span> int i = RANDOM.nextInt(numServers);<a name="line.1561"></a>
-<span class="sourceLineNo">1562</span> sn = servers.get(i);<a name="line.1562"></a>
-<span class="sourceLineNo">1563</span> if (!usedSNs.contains(sn)) {<a name="line.1563"></a>
-<span class="sourceLineNo">1564</span> usedSNs.add(sn);<a name="line.1564"></a>
-<span class="sourceLineNo">1565</span> }<a name="line.1565"></a>
-<span class="sourceLineNo">1566</span> } while (cluster.wouldLowerAvailability(regionInfo, sn)<a name="line.1566"></a>
-<span class="sourceLineNo">1567</span> && iterations++ < maxIterations);<a name="line.1567"></a>
-<span class="sourceLineNo">1568</span> if (iterations >= maxIterations) {<a name="line.1568"></a>
-<span class="sourceLineNo">1569</span> // We have reached the max. Means the servers that we collected is still lowering the<a name="line.1569"></a>
-<span class="sourceLineNo">1570</span> // availability<a name="line.1570"></a>
-<span class="sourceLineNo">1571</span> for (ServerName unusedServer : servers) {<a name="line.1571"></a>
-<span class="sourceLineNo">1572</span> if (!usedSNs.contains(unusedServer)) {<a name="line.1572"></a>
-<span class="sourceLineNo">1573</span> // check if any other unused server is there for us to use.<a name="line.1573"></a>
-<span class="sourceLineNo">1574</span> // If so use it. Else we have not other go but to go with one of them<a name="line.1574"></a>
-<span class="sourceLineNo">1575</span> if (!cluster.wouldLowerAvailability(regionInfo, unusedServer)) {<a name="line.1575"></a>
-<span class="sourceLineNo">1576</span> sn = unusedServer;<a name="line.1576"></a>
-<span class="sourceLineNo">1577</span> break;<a name="line.1577"></a>
-<span class="sourceLineNo">1578</span> }<a name="line.1578"></a>
-<span class="sourceLineNo">1579</span> }<a name="line.1579"></a>
-<span class="sourceLineNo">1580</span> }<a name="line.1580"></a>
-<span class="sourceLineNo">1581</span> }<a name="line.1581"></a>
-<span class="sourceLineNo">1582</span> cluster.doAssignRegion(regionInfo, sn);<a name="line.1582"></a>
-<span class="sourceLineNo">1583</span> return sn;<a name="line.1583"></a>
-<span class="sourceLineNo">1584</span> }<a name="line.1584"></a>
-<span class="sourceLineNo">1585</span><a name="line.1585"></a>
-<span class="sourceLineNo">1586</span> /**<a name="line.1586"></a>
-<span class="sourceLineNo">1587</span> * Round robin a list of regions to a list of servers<a name="line.1587"></a>
-<span class="sourceLineNo">1588</span> */<a name="line.1588"></a>
-<span class="sourceLineNo">1589</span> private void roundRobinAssignment(Cluster cluster, List<RegionInfo> regions,<a name="line.1589"></a>
-<span class="sourceLineNo">1590</span> List<RegionInfo> unassignedRegions, List<ServerName> servers,<a name="line.1590"></a>
-<span class="sourceLineNo">1591</span> Map<ServerName, List<RegionInfo>> assignments) {<a name="line.1591"></a>
-<span class="sourceLineNo">1592</span><a name="line.1592"></a>
-<span class="sourceLineNo">1593</span> int numServers = servers.size();<a name="line.1593"></a>
-<span class="sourceLineNo">1594</span> int numRegions = regions.size();<a name="line.1594"></a>
-<span class="sourceLineNo">1595</span> int max = (int) Math.ceil((float) numRegions / numServers);<a name="line.1595"></a>
-<span class="sourceLineNo">1596</span> int serverIdx = 0;<a name="line.1596"></a>
-<span class="sourceLineNo">1597</span> if (numServers > 1) {<a name="line.1597"></a>
-<span class="sourceLineNo">1598</span> serverIdx = RANDOM.nextInt(numServers);<a name="line.1598"></a>
-<span class="sourceLineNo">1599</span> }<a name="line.1599"></a>
-<span class="sourceLineNo">1600</span> int regionIdx = 0;<a name="line.1600"></a>
-<span class="sourceLineNo">1601</span><a name="line.1601"></a>
-<span class="sourceLineNo">1602</span> for (int j = 0; j < numServers; j++) {<a name="line.1602"></a>
-<span class="sourceLineNo">1603</span> ServerName server = servers.get((j + serverIdx) % numServers);<a name="line.1603"></a>
-<span class="sourceLineNo">1604</span> List<RegionInfo> serverRegions = new ArrayList<>(max);<a name="line.1604"></a>
-<span class="sourceLineNo">1605</span> for (int i = regionIdx; i < numRegions; i += numServers) {<a name="line.1605"></a>
-<span class="sourceLineNo">1606</span> RegionInfo region = regions.get(i % numRegions);<a name="line.1606"></a>
-<span class="sourceLineNo">1607</span> if (cluster.wouldLowerAvailability(region, server)) {<a name="line.1607"></a>
-<span class="sourceLineNo">1608</span> unassignedRegions.add(region);<a name="line.1608"></a>
-<span class="sourceLineNo">1609</span> } else {<a name="line.1609"></a>
-<span class="sourceLineNo">1610</span> serverRegions.add(region);<a name="line.1610"></a>
-<span class="sourceLineNo">1611</span> cluster.doAssignRegion(region, server);<a name="line.1611"></a>
-<span class="sourceLineNo">1612</span> }<a name="line.1612"></a>
-<span class="sourceLineNo">1613</span> }<a name="line.1613"></a>
-<span class="sourceLineNo">1614</span> assignments.put(server, serverRegions);<a name="line.1614"></a>
-<span class="sourceLineNo">1615</span> regionIdx++;<a name="line.1615"></a>
-<span class="sourceLineNo">1616</span> }<a name="line.1616"></a>
-<span class="sourceLineNo">1617</span> }<a name="line.1617"></a>
-<span class="sourceLineNo">1618</span><a name="line.1618"></a>
-<span class="sourceLineNo">1619</span> protected Map<ServerName, List<RegionInfo>> getRegionAssignmentsByServer(<a name="line.1619"></a>
-<span class="sourceLineNo">1620</span> Collection<RegionInfo> regions) {<a name="line.1620"></a>
-<span class="sourceLineNo">1621</span> if (this.services != null && this.services.getAssignmentManager() != null) {<a name="line.1621"></a>
-<span class="sourceLineNo">1622</span> return this.services.getAssignmentManager().getSnapShotOfAssignment(regions);<a name="line.1622"></a>
-<span class="sourceLineNo">1623</span> } else {<a name="line.1623"></a>
-<span class="sourceLineNo">1624</span> return new HashMap<>();<a name="line.1624"></a>
-<span class="sourceLineNo">1625</span> }<a name="line.1625"></a>
-<span class="sourceLineNo">1626</span> }<a name="line.1626"></a>
-<span class="sourceLineNo">1627</span><a name="line.1627"></a>
-<span class="sourceLineNo">1628</span> @Override<a name="line.1628"></a>
-<span class="sourceLineNo">1629</span> public void onConfigurationChange(Configuration conf) {<a name="line.1629"></a>
-<span class="sourceLineNo">1630</span> }<a name="line.1630"></a>
-<span class="sourceLineNo">1631</span>}<a name="line.1631"></a>
+<span class="sourceLineNo">1545</span> public boolean isStopped() {<a name="line.1545"></a>
+<span class="sourceLineNo">1546</span> return stopped;<a name="line.1546"></a>
+<span class="sourceLineNo">1547</span> }<a name="line.1547"></a>
+<span class="sourceLineNo">1548</span><a name="line.1548"></a>
+<span class="sourceLineNo">1549</span> @Override<a name="line.1549"></a>
+<span class="sourceLineNo">1550</span> public void stop(String why) {<a name="line.1550"></a>
+<span class="sourceLineNo">1551</span> LOG.info("Load Balancer stop requested: "+why);<a name="line.1551"></a>
+<span class="sourceLineNo">1552</span> stopped = true;<a name="line.1552"></a>
+<span class="sourceLineNo">1553</span> }<a name="line.1553"></a>
+<span class="sourceLineNo">1554</span><a name="line.1554"></a>
+<span class="sourceLineNo">1555</span> /**<a name="line.1555"></a>
+<span class="sourceLineNo">1556</span> * Used to assign a single region to a random server.<a name="line.1556"></a>
+<span class="sourceLineNo">1557</span> */<a name="line.1557"></a>
+<span class="sourceLineNo">1558</span> private ServerName randomAssignment(Cluster cluster, RegionInfo regionInfo,<a name="line.1558"></a>
+<span class="sourceLineNo">1559</span> List<ServerName> servers) {<a name="line.1559"></a>
+<span class="sourceLineNo">1560</span> int numServers = servers.size(); // servers is not null, numServers > 1<a name="line.1560"></a>
+<span class="sourceLineNo">1561</span> ServerName sn = null;<a name="line.1561"></a>
+<span class="sourceLineNo">1562</span> final int maxIterations = numServers * 4;<a name="line.1562"></a>
+<span class="sourceLineNo">1563</span> int iterations = 0;<a name="line.1563"></a>
+<span class="sourceLineNo">1564</span> List<ServerName> usedSNs = new ArrayList<>(servers.size());<a name="line.1564"></a>
+<span class="sourceLineNo">1565</span> do {<a name="line.1565"></a>
+<span class="sourceLineNo">1566</span> int i = RANDOM.nextInt(numServers);<a name="line.1566"></a>
+<span class="sourceLineNo">1567</span> sn = servers.get(i);<a name="line.1567"></a>
+<span class="sourceLineNo">1568</span> if (!usedSNs.contains(sn)) {<a name="line.1568"></a>
+<span class="sourceLineNo">1569</span> usedSNs.add(sn);<a name="line.1569"></a>
+<span class="sourceLineNo">1570</span> }<a name="line.1570"></a>
+<span class="sourceLineNo">1571</span> } while (cluster.wouldLowerAvailability(regionInfo, sn)<a name="line.1571"></a>
+<span class="sourceLineNo">1572</span> && iterations++ < maxIterations);<a name="line.1572"></a>
+<span class="sourceLineNo">1573</span> if (iterations >= maxIterations) {<a name="line.1573"></a>
+<span class="sourceLineNo">1574</span> // We have reached the max. Means the servers that we collected is still lowering the<a name="line.1574"></a>
+<span class="sourceLineNo">1575</span> // availability<a name="line.1575"></a>
+<span class="sourceLineNo">1576</span> for (ServerName unusedServer : servers) {<a name="line.1576"></a>
+<span class="sourceLineNo">1577</span> if (!usedSNs.contains(unusedServer)) {<a name="line.1577"></a>
+<span class="sourceLineNo">1578</span> // check if any other unused server is there for us to use.<a name="line.1578"></a>
+<span class="sourceLineNo">1579</span> // If so use it. Else we have not other go but to go with one of them<a name="line.1579"></a>
+<span class="sourceLineNo">1580</span> if (!cluster.wouldLowerAvailability(regionInfo, unusedServer)) {<a name="line.1580"></a>
+<span class="sourceLineNo">1581</span> sn = unusedServer;<a name="line.1581"></a>
+<span class="sourceLineNo">1582</span> break;<a name="line.1582"></a>
+<span class="sourceLineNo">1583</span> }<a name="line.1583"></a>
+<span class="sourceLineNo">1584</span> }<a name="line.1584"></a>
+<span class="sourceLineNo">1585</span> }<a name="line.1585"></a>
+<span class="sourceLineNo">1586</span> }<a name="line.1586"></a>
+<span class="sourceLineNo">1587</span> cluster.doAssignRegion(regionInfo, sn);<a name="line.1587"></a>
+<span class="sourceLineNo">1588</span> return sn;<a name="line.1588"></a>
+<span class="sourceLineNo">1589</span> }<a name="line.1589"></a>
+<span class="sourceLineNo">1590</span><a name="line.1590"></a>
+<span class="sourceLineNo">1591</span> /**<a name="line.1591"></a>
+<span class="sourceLineNo">1592</span> * Round robin a list of regions to a list of servers<a name="line.1592"></a>
+<span class="sourceLineNo">1593</span> */<a name="line.1593"></a>
+<span class="sourceLineNo">1594</span> private void roundRobinAssignment(Cluster cluster, List<RegionInfo> regions,<a name="line.1594"></a>
+<span class="sourceLineNo">1595</span> List<RegionInfo> unassignedRegions, List<ServerName> servers,<a name="line.1595"></a>
+<span class="sourceLineNo">1596</span> Map<ServerName, List<RegionInfo>> assignments) {<a name="line.1596"></a>
+<span class="sourceLineNo">1597</span><a name="line.1597"></a>
+<span class="sourceLineNo">1598</span> int numServers = servers.size();<a name="line.1598"></a>
+<span class="sourceLineNo">1599</span> int numRegions = regions.size();<a name="line.1599"></a>
+<span class="sourceLineNo">1600</span> int max = (int) Math.ceil((float) numRegions / numServers);<a name="line.1600"></a>
+<span class="sourceLineNo">1601</span> int serverIdx = 0;<a name="line.1601"></a>
+<span class="sourceLineNo">1602</span> if (numServers > 1) {<a name="line.1602"></a>
+<span class="sourceLineNo">1603</span> serverIdx = RANDOM.nextInt(numServers);<a name="line.1603"></a>
+<span class="sourceLineNo">1604</span> }<a name="line.1604"></a>
+<span class="sourceLineNo">1605</span> int regionIdx = 0;<a name="line.1605"></a>
+<span class="sourceLineNo">1606</span><a name="line.1606"></a>
+<span class="sourceLineNo">1607</span> for (int j = 0; j < numServers; j++) {<a name="line.1607"></a>
+<span class="sourceLineNo">1608</span> ServerName server = servers.get((j + serverIdx) % numServers);<a name="line.1608"></a>
+<span class="sourceLineNo">1609</span> List<RegionInfo> serverRegions = new ArrayList<>(max);<a name="line.1609"></a>
+<span class="sourceLineNo">1610</span> for (int i = regionIdx; i < numRegions; i += numServers) {<a name="line.1610"></a>
+<span class="sourceLineNo">1611</span> RegionInfo region = regions.get(i % numRegions);<a name="line.1611"></a>
+<span class="sourceLineNo">1612</span> if (cluster.wouldLowerAvailability(region, server)) {<a name="line.1612"></a>
+<span class="sourceLineNo">1613</span> unassignedRegions.add(region);<a name="line.1613"></a>
+<span class="sourceLineNo">1614</span> } else {<a name="line.1614"></a>
+<span class="sourceLineNo">1615</span> serverRegions.add(region);<a name="line.1615"></a>
+<span class="sourceLineNo">1616</span> cluster.doAssignRegion(region, server);<a name="line.1616"></a>
+<span class="sourceLineNo">1617</span> }<a name="line.1617"></a>
+<span class="sourceLineNo">1618</span> }<a name="line.1618"></a>
+<span class="sourceLineNo">1619</span> assignments.put(server, serverRegions);<a name="line.1619"></a>
+<span class="sourceLineNo">1620</span> regionIdx++;<a name="line.1620"></a>
+<span class="sourceLineNo">1621</span> }<a name="line.1621"></a>
+<span class="sourceLineNo">1622</span> }<a name="line.1622"></a>
+<span class="sourceLineNo">1623</span><a name="line.1623"></a>
+<span class="sourceLineNo">1624</span> protected Map<ServerName, List<RegionInfo>> getRegionAssignmentsByServer(<a name="line.1624"></a>
+<span class="sourceLineNo">1625</span> Collection<RegionInfo> regions) {<a name="line.1625"></a>
+<span class="sourceLineNo">1626</span> if (this.services != null && this.services.getAssignmentManager() != null) {<a name="line.1626"></a>
+<span class="sourceLineNo">1627</span> return this.services.getAssignmentManager().getSnapShotOfAssignment(regions);<a name="line.1627"></a>
+<span class="sourceLineNo">1628</span> } else {<a name="line.1628"></a>
+<span class="sourceLineNo">1629</span> return new HashMap<>();<a name="line.1629"></a>
+<span class="sourceLineNo">1630</span> }<a name="line.1630"></a>
+<span class="sourceLineNo">1631</span> }<a name="line.1631"></a>
+<span class="sourceLineNo">1632</span><a name="line.1632"></a>
+<span class="sourceLineNo">1633</span> @Override<a name="line.1633"></a>
+<span class="sourceLineNo">1634</span> public void onConfigurationChange(Configuration conf) {<a name="line.1634"></a>
+<span class="sourceLineNo">1635</span> }<a name="line.1635"></a>
+<span class="sourceLineNo">1636</span>}<a name="line.1636"></a>
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/ab597584/devapidocs/src-html/org/apache/hadoop/hbase/master/balancer/BaseLoadBalancer.Cluster.LocalityType.html
----------------------------------------------------------------------
diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/master/balancer/BaseLoadBalancer.Cluster.LocalityType.html b/devapidocs/src-html/org/apache/hadoop/hbase/master/balancer/BaseLoadBalancer.Cluster.LocalityType.html
index d974429..e478f39 100644
--- a/devapidocs/src-html/org/apache/hadoop/hbase/master/balancer/BaseLoadBalancer.Cluster.LocalityType.html
+++ b/devapidocs/src-html/org/apache/hadoop/hbase/master/balancer/BaseLoadBalancer.Cluster.LocalityType.html
@@ -42,32 +42,32 @@
<span class="sourceLineNo">034</span>import java.util.TreeMap;<a name="line.34"></a>
<span class="sourceLineNo">035</span>import java.util.function.Predicate;<a name="line.35"></a>
<span class="sourceLineNo">036</span>import java.util.stream.Collectors;<a name="line.36"></a>
-<span class="sourceLineNo">037</span>import org.apache.commons.lang3.NotImplementedException;<a name="line.37"></a>
-<span class="sourceLineNo">038</span>import org.apache.hadoop.conf.Configuration;<a name="line.38"></a>
-<span class="sourceLineNo">039</span>import org.apache.hadoop.hbase.ClusterMetrics;<a name="line.39"></a>
-<span class="sourceLineNo">040</span>import org.apache.hadoop.hbase.HBaseConfiguration;<a name="line.40"></a>
-<span class="sourceLineNo">041</span>import org.apache.hadoop.hbase.HBaseIOException;<a name="line.41"></a>
-<span class="sourceLineNo">042</span>import org.apache.hadoop.hbase.HConstants;<a name="line.42"></a>
-<span class="sourceLineNo">043</span>import org.apache.hadoop.hbase.HDFSBlocksDistribution;<a name="line.43"></a>
-<span class="sourceLineNo">044</span>import org.apache.hadoop.hbase.ServerMetrics;<a name="line.44"></a>
-<span class="sourceLineNo">045</span>import org.apache.hadoop.hbase.ServerName;<a name="line.45"></a>
-<span class="sourceLineNo">046</span>import org.apache.hadoop.hbase.TableName;<a name="line.46"></a>
-<span class="sourceLineNo">047</span>import org.apache.hadoop.hbase.client.RegionInfo;<a name="line.47"></a>
-<span class="sourceLineNo">048</span>import org.apache.hadoop.hbase.client.RegionReplicaUtil;<a name="line.48"></a>
-<span class="sourceLineNo">049</span>import org.apache.hadoop.hbase.master.LoadBalancer;<a name="line.49"></a>
-<span class="sourceLineNo">050</span>import org.apache.hadoop.hbase.master.MasterServices;<a name="line.50"></a>
-<span class="sourceLineNo">051</span>import org.apache.hadoop.hbase.master.RackManager;<a name="line.51"></a>
-<span class="sourceLineNo">052</span>import org.apache.hadoop.hbase.master.RegionPlan;<a name="line.52"></a>
-<span class="sourceLineNo">053</span>import org.apache.hadoop.hbase.master.balancer.BaseLoadBalancer.Cluster.Action.Type;<a name="line.53"></a>
-<span class="sourceLineNo">054</span>import org.apache.yetus.audience.InterfaceAudience;<a name="line.54"></a>
-<span class="sourceLineNo">055</span>import org.slf4j.Logger;<a name="line.55"></a>
-<span class="sourceLineNo">056</span>import org.slf4j.LoggerFactory;<a name="line.56"></a>
-<span class="sourceLineNo">057</span><a name="line.57"></a>
-<span class="sourceLineNo">058</span>import org.apache.hbase.thirdparty.com.google.common.annotations.VisibleForTesting;<a name="line.58"></a>
-<span class="sourceLineNo">059</span>import org.apache.hbase.thirdparty.com.google.common.base.Joiner;<a name="line.59"></a>
-<span class="sourceLineNo">060</span>import org.apache.hbase.thirdparty.com.google.common.collect.ArrayListMultimap;<a name="line.60"></a>
-<span class="sourceLineNo">061</span>import org.apache.hbase.thirdparty.com.google.common.collect.Lists;<a name="line.61"></a>
-<span class="sourceLineNo">062</span>import org.apache.hbase.thirdparty.com.google.common.collect.Sets;<a name="line.62"></a>
+<span class="sourceLineNo">037</span><a name="line.37"></a>
+<span class="sourceLineNo">038</span>import org.apache.commons.lang3.NotImplementedException;<a name="line.38"></a>
+<span class="sourceLineNo">039</span>import org.apache.hadoop.conf.Configuration;<a name="line.39"></a>
+<span class="sourceLineNo">040</span>import org.apache.hadoop.hbase.ClusterMetrics;<a name="line.40"></a>
+<span class="sourceLineNo">041</span>import org.apache.hadoop.hbase.HBaseConfiguration;<a name="line.41"></a>
+<span class="sourceLineNo">042</span>import org.apache.hadoop.hbase.HBaseIOException;<a name="line.42"></a>
+<span class="sourceLineNo">043</span>import org.apache.hadoop.hbase.HConstants;<a name="line.43"></a>
+<span class="sourceLineNo">044</span>import org.apache.hadoop.hbase.HDFSBlocksDistribution;<a name="line.44"></a>
+<span class="sourceLineNo">045</span>import org.apache.hadoop.hbase.ServerMetrics;<a name="line.45"></a>
+<span class="sourceLineNo">046</span>import org.apache.hadoop.hbase.ServerName;<a name="line.46"></a>
+<span class="sourceLineNo">047</span>import org.apache.hadoop.hbase.TableName;<a name="line.47"></a>
+<span class="sourceLineNo">048</span>import org.apache.hadoop.hbase.client.RegionInfo;<a name="line.48"></a>
+<span class="sourceLineNo">049</span>import org.apache.hadoop.hbase.client.RegionReplicaUtil;<a name="line.49"></a>
+<span class="sourceLineNo">050</span>import org.apache.hadoop.hbase.master.LoadBalancer;<a name="line.50"></a>
+<span class="sourceLineNo">051</span>import org.apache.hadoop.hbase.master.MasterServices;<a name="line.51"></a>
+<span class="sourceLineNo">052</span>import org.apache.hadoop.hbase.master.RackManager;<a name="line.52"></a>
+<span class="sourceLineNo">053</span>import org.apache.hadoop.hbase.master.RegionPlan;<a name="line.53"></a>
+<span class="sourceLineNo">054</span>import org.apache.hadoop.hbase.master.balancer.BaseLoadBalancer.Cluster.Action.Type;<a name="line.54"></a>
+<span class="sourceLineNo">055</span>import org.apache.hbase.thirdparty.com.google.common.annotations.VisibleForTesting;<a name="line.55"></a>
+<span class="sourceLineNo">056</span>import org.apache.hbase.thirdparty.com.google.common.base.Joiner;<a name="line.56"></a>
+<span class="sourceLineNo">057</span>import org.apache.hbase.thirdparty.com.google.common.collect.ArrayListMultimap;<a name="line.57"></a>
+<span class="sourceLineNo">058</span>import org.apache.hbase.thirdparty.com.google.common.collect.Lists;<a name="line.58"></a>
+<span class="sourceLineNo">059</span>import org.apache.hbase.thirdparty.com.google.common.collect.Sets;<a name="line.59"></a>
+<span class="sourceLineNo">060</span>import org.apache.yetus.audience.InterfaceAudience;<a name="line.60"></a>
+<span class="sourceLineNo">061</span>import org.slf4j.Logger;<a name="line.61"></a>
+<span class="sourceLineNo">062</span>import org.slf4j.LoggerFactory;<a name="line.62"></a>
<span class="sourceLineNo">063</span><a name="line.63"></a>
<span class="sourceLineNo">064</span>/**<a name="line.64"></a>
<span class="sourceLineNo">065</span> * The base class for load balancers. It provides the the functions used to by<a name="line.65"></a>
@@ -1462,181 +1462,186 @@
<span class="sourceLineNo">1454</span> for (Map.Entry<RegionInfo, ServerName> entry : regions.entrySet()) {<a name="line.1454"></a>
<span class="sourceLineNo">1455</span> RegionInfo region = entry.getKey();<a name="line.1455"></a>
<span class="sourceLineNo">1456</span> ServerName oldServerName = entry.getValue();<a name="line.1456"></a>
-<span class="sourceLineNo">1457</span> if (!hasRegionReplica && !RegionReplicaUtil.isDefaultReplica(region)) {<a name="line.1457"></a>
-<span class="sourceLineNo">1458</span> hasRegionReplica = true;<a name="line.1458"></a>
-<span class="sourceLineNo">1459</span> }<a name="line.1459"></a>
-<span class="sourceLineNo">1460</span> List<ServerName> localServers = new ArrayList<>();<a name="line.1460"></a>
-<span class="sourceLineNo">1461</span> if (oldServerName != null) {<a name="line.1461"></a>
-<span class="sourceLineNo">1462</span> localServers = serversByHostname.get(oldServerName.getHostnameLowerCase());<a name="line.1462"></a>
-<span class="sourceLineNo">1463</span> }<a name="line.1463"></a>
-<span class="sourceLineNo">1464</span> if (localServers.isEmpty()) {<a name="line.1464"></a>
-<span class="sourceLineNo">1465</span> // No servers on the new cluster match up with this hostname, assign randomly, later.<a name="line.1465"></a>
-<span class="sourceLineNo">1466</span> randomAssignRegions.add(region);<a name="line.1466"></a>
-<span class="sourceLineNo">1467</span> if (oldServerName != null) {<a name="line.1467"></a>
-<span class="sourceLineNo">1468</span> oldHostsNoLongerPresent.add(oldServerName.getHostnameLowerCase());<a name="line.1468"></a>
-<span class="sourceLineNo">1469</span> }<a name="line.1469"></a>
-<span class="sourceLineNo">1470</span> } else if (localServers.size() == 1) {<a name="line.1470"></a>
-<span class="sourceLineNo">1471</span> // the usual case - one new server on same host<a name="line.1471"></a>
-<span class="sourceLineNo">1472</span> ServerName target = localServers.get(0);<a name="line.1472"></a>
-<span class="sourceLineNo">1473</span> assignments.get(target).add(region);<a name="line.1473"></a>
-<span class="sourceLineNo">1474</span> numRetainedAssigments++;<a name="line.1474"></a>
-<span class="sourceLineNo">1475</span> } else {<a name="line.1475"></a>
-<span class="sourceLineNo">1476</span> // multiple new servers in the cluster on this same host<a name="line.1476"></a>
-<span class="sourceLineNo">1477</span> if (localServers.contains(oldServerName)) {<a name="line.1477"></a>
-<span class="sourceLineNo">1478</span> assignments.get(oldServerName).add(region);<a name="line.1478"></a>
-<span class="sourceLineNo">1479</span> numRetainedAssigments++;<a name="line.1479"></a>
-<span class="sourceLineNo">1480</span> } else {<a name="line.1480"></a>
-<span class="sourceLineNo">1481</span> ServerName target = null;<a name="line.1481"></a>
-<span class="sourceLineNo">1482</span> for (ServerName tmp : localServers) {<a name="line.1482"></a>
-<span class="sourceLineNo">1483</span> if (tmp.getPort() == oldServerName.getPort()) {<a name="line.1483"></a>
-<span class="sourceLineNo">1484</span> target = tmp;<a name="line.1484"></a>
-<span class="sourceLineNo">1485</span> assignments.get(tmp).add(region);<a name="line.1485"></a>
-<span class="sourceLineNo">1486</span> numRetainedAssigments++;<a name="line.1486"></a>
-<span class="sourceLineNo">1487</span> break;<a name="line.1487"></a>
-<span class="sourceLineNo">1488</span> }<a name="line.1488"></a>
-<span class="sourceLineNo">1489</span> }<a name="line.1489"></a>
-<span class="sourceLineNo">1490</span> if (target == null) {<a name="line.1490"></a>
-<span class="sourceLineNo">1491</span> randomAssignRegions.add(region);<a name="line.1491"></a>
-<span class="sourceLineNo">1492</span> }<a name="line.1492"></a>
-<span class="sourceLineNo">1493</span> }<a name="line.1493"></a>
-<span class="sourceLineNo">1494</span> }<a name="line.1494"></a>
-<span class="sourceLineNo">1495</span> }<a name="line.1495"></a>
-<span class="sourceLineNo">1496</span><a name="line.1496"></a>
-<span class="sourceLineNo">1497</span> // If servers from prior assignment aren't present, then lets do randomAssignment on regions.<a name="line.1497"></a>
-<span class="sourceLineNo">1498</span> if (randomAssignRegions.size() > 0) {<a name="line.1498"></a>
-<span class="sourceLineNo">1499</span> Cluster cluster = createCluster(servers, regions.keySet(), hasRegionReplica);<a name="line.1499"></a>
-<span class="sourceLineNo">1500</span> for (Map.Entry<ServerName, List<RegionInfo>> entry : assignments.entrySet()) {<a name="line.1500"></a>
-<span class="sourceLineNo">1501</span> ServerName sn = entry.getKey();<a name="line.1501"></a>
-<span class="sourceLineNo">1502</span> for (RegionInfo region : entry.getValue()) {<a name="line.1502"></a>
-<span class="sourceLineNo">1503</span> cluster.doAssignRegion(region, sn);<a name="line.1503"></a>
-<span class="sourceLineNo">1504</span> }<a name="line.1504"></a>
-<span class="sourceLineNo">1505</span> }<a name="line.1505"></a>
-<span class="sourceLineNo">1506</span> for (RegionInfo region : randomAssignRegions) {<a name="line.1506"></a>
-<span class="sourceLineNo">1507</span> ServerName target = randomAssignment(cluster, region, servers);<a name="line.1507"></a>
-<span class="sourceLineNo">1508</span> assignments.get(target).add(region);<a name="line.1508"></a>
-<span class="sourceLineNo">1509</span> numRandomAssignments++;<a name="line.1509"></a>
+<span class="sourceLineNo">1457</span> // In the current set of regions even if one has region replica let us go with<a name="line.1457"></a>
+<span class="sourceLineNo">1458</span> // getting the entire snapshot<a name="line.1458"></a>
+<span class="sourceLineNo">1459</span> if (this.services != null && this.services.getAssignmentManager() != null) { // for tests<a name="line.1459"></a>
+<span class="sourceLineNo">1460</span> if (!hasRegionReplica && this.services.getAssignmentManager().getRegionStates()<a name="line.1460"></a>
+<span class="sourceLineNo">1461</span> .isReplicaAvailableForRegion(region)) {<a name="line.1461"></a>
+<span class="sourceLineNo">1462</span> hasRegionReplica = true;<a name="line.1462"></a>
+<span class="sourceLineNo">1463</span> }<a name="line.1463"></a>
+<span class="sourceLineNo">1464</span> }<a name="line.1464"></a>
+<span class="sourceLineNo">1465</span> List<ServerName> localServers = new ArrayList<>();<a name="line.1465"></a>
+<span class="sourceLineNo">1466</span> if (oldServerName != null) {<a name="line.1466"></a>
+<span class="sourceLineNo">1467</span> localServers = serversByHostname.get(oldServerName.getHostnameLowerCase());<a name="line.1467"></a>
+<span class="sourceLineNo">1468</span> }<a name="line.1468"></a>
+<span class="sourceLineNo">1469</span> if (localServers.isEmpty()) {<a name="line.1469"></a>
+<span class="sourceLineNo">1470</span> // No servers on the new cluster match up with this hostname, assign randomly, later.<a name="line.1470"></a>
+<span class="sourceLineNo">1471</span> randomAssignRegions.add(region);<a name="line.1471"></a>
+<span class="sourceLineNo">1472</span> if (oldServerName != null) {<a name="line.1472"></a>
+<span class="sourceLineNo">1473</span> oldHostsNoLongerPresent.add(oldServerName.getHostnameLowerCase());<a name="line.1473"></a>
+<span class="sourceLineNo">1474</span> }<a name="line.1474"></a>
+<span class="sourceLineNo">1475</span> } else if (localServers.size() == 1) {<a name="line.1475"></a>
+<span class="sourceLineNo">1476</span> // the usual case - one new server on same host<a name="line.1476"></a>
+<span class="sourceLineNo">1477</span> ServerName target = localServers.get(0);<a name="line.1477"></a>
+<span class="sourceLineNo">1478</span> assignments.get(target).add(region);<a name="line.1478"></a>
+<span class="sourceLineNo">1479</span> numRetainedAssigments++;<a name="line.1479"></a>
+<span class="sourceLineNo">1480</span> } else {<a name="line.1480"></a>
+<span class="sourceLineNo">1481</span> // multiple new servers in the cluster on this same host<a name="line.1481"></a>
+<span class="sourceLineNo">1482</span> if (localServers.contains(oldServerName)) {<a name="line.1482"></a>
+<span class="sourceLineNo">1483</span> assignments.get(oldServerName).add(region);<a name="line.1483"></a>
+<span class="sourceLineNo">1484</span> numRetainedAssigments++;<a name="line.1484"></a>
+<span class="sourceLineNo">1485</span> } else {<a name="line.1485"></a>
+<span class="sourceLineNo">1486</span> ServerName target = null;<a name="line.1486"></a>
+<span class="sourceLineNo">1487</span> for (ServerName tmp : localServers) {<a name="line.1487"></a>
+<span class="sourceLineNo">1488</span> if (tmp.getPort() == oldServerName.getPort()) {<a name="line.1488"></a>
+<span class="sourceLineNo">1489</span> target = tmp;<a name="line.1489"></a>
+<span class="sourceLineNo">1490</span> assignments.get(tmp).add(region);<a name="line.1490"></a>
+<span class="sourceLineNo">1491</span> numRetainedAssigments++;<a name="line.1491"></a>
+<span class="sourceLineNo">1492</span> break;<a name="line.1492"></a>
+<span class="sourceLineNo">1493</span> }<a name="line.1493"></a>
+<span class="sourceLineNo">1494</span> }<a name="line.1494"></a>
+<span class="sourceLineNo">1495</span> if (target == null) {<a name="line.1495"></a>
+<span class="sourceLineNo">1496</span> randomAssignRegions.add(region);<a name="line.1496"></a>
+<span class="sourceLineNo">1497</span> }<a name="line.1497"></a>
+<span class="sourceLineNo">1498</span> }<a name="line.1498"></a>
+<span class="sourceLineNo">1499</span> }<a name="line.1499"></a>
+<span class="sourceLineNo">1500</span> }<a name="line.1500"></a>
+<span class="sourceLineNo">1501</span><a name="line.1501"></a>
+<span class="sourceLineNo">1502</span> // If servers from prior assignment aren't present, then lets do randomAssignment on regions.<a name="line.1502"></a>
+<span class="sourceLineNo">1503</span> if (randomAssignRegions.size() > 0) {<a name="line.1503"></a>
+<span class="sourceLineNo">1504</span> Cluster cluster = createCluster(servers, regions.keySet(), hasRegionReplica);<a name="line.1504"></a>
+<span class="sourceLineNo">1505</span> for (Map.Entry<ServerName, List<RegionInfo>> entry : assignments.entrySet()) {<a name="line.1505"></a>
+<span class="sourceLineNo">1506</span> ServerName sn = entry.getKey();<a name="line.1506"></a>
+<span class="sourceLineNo">1507</span> for (RegionInfo region : entry.getValue()) {<a name="line.1507"></a>
+<span class="sourceLineNo">1508</span> cluster.doAssignRegion(region, sn);<a name="line.1508"></a>
+<span class="sourceLineNo">1509</span> }<a name="line.1509"></a>
<span class="sourceLineNo">1510</span> }<a name="line.1510"></a>
-<span class="sourceLineNo">1511</span> }<a name="line.1511"></a>
-<span class="sourceLineNo">1512</span><a name="line.1512"></a>
-<span class="sourceLineNo">1513</span> String randomAssignMsg = "";<a name="line.1513"></a>
-<span class="sourceLineNo">1514</span> if (numRandomAssignments > 0) {<a name="line.1514"></a>
-<span class="sourceLineNo">1515</span> randomAssignMsg =<a name="line.1515"></a>
-<span class="sourceLineNo">1516</span> numRandomAssignments + " regions were assigned "<a name="line.1516"></a>
-<span class="sourceLineNo">1517</span> + "to random hosts, since the old hosts for these regions are no "<a name="line.1517"></a>
-<span class="sourceLineNo">1518</span> + "longer present in the cluster. These hosts were:\n "<a name="line.1518"></a>
-<span class="sourceLineNo">1519</span> + Joiner.on("\n ").join(oldHostsNoLongerPresent);<a name="line.1519"></a>
-<span class="sourceLineNo">1520</span> }<a name="line.1520"></a>
-<span class="sourceLineNo">1521</span><a name="line.1521"></a>
-<span class="sourceLineNo">1522</span> LOG.info("Reassigned " + regions.size() + " regions. " + numRetainedAssigments<a name="line.1522"></a>
-<span class="sourceLineNo">1523</span> + " retained the pre-restart assignment. " + randomAssignMsg);<a name="line.1523"></a>
-<span class="sourceLineNo">1524</span> return assignments;<a name="line.1524"></a>
-<span class="sourceLineNo">1525</span> }<a name="line.1525"></a>
+<span class="sourceLineNo">1511</span> for (RegionInfo region : randomAssignRegions) {<a name="line.1511"></a>
+<span class="sourceLineNo">1512</span> ServerName target = randomAssignment(cluster, region, servers);<a name="line.1512"></a>
+<span class="sourceLineNo">1513</span> assignments.get(target).add(region);<a name="line.1513"></a>
+<span class="sourceLineNo">1514</span> numRandomAssignments++;<a name="line.1514"></a>
+<span class="sourceLineNo">1515</span> }<a name="line.1515"></a>
+<span class="sourceLineNo">1516</span> }<a name="line.1516"></a>
+<span class="sourceLineNo">1517</span><a name="line.1517"></a>
+<span class="sourceLineNo">1518</span> String randomAssignMsg = "";<a name="line.1518"></a>
+<span class="sourceLineNo">1519</span> if (numRandomAssignments > 0) {<a name="line.1519"></a>
+<span class="sourceLineNo">1520</span> randomAssignMsg =<a name="line.1520"></a>
+<span class="sourceLineNo">1521</span> numRandomAssignments + " regions were assigned "<a name="line.1521"></a>
+<span class="sourceLineNo">1522</span> + "to random hosts, since the old hosts for these regions are no "<a name="line.1522"></a>
+<span class="sourceLineNo">1523</span> + "longer present in the cluster. These hosts were:\n "<a name="line.1523"></a>
+<span class="sourceLineNo">1524</span> + Joiner.on("\n ").join(oldHostsNoLongerPresent);<a name="line.1524"></a>
+<span class="sourceLineNo">1525</span> }<a name="line.1525"></a>
<span class="sourceLineNo">1526</span><a name="line.1526"></a>
-<span class="sourceLineNo">1527</span> @Override<a name="line.1527"></a>
-<span class="sourceLineNo">1528</span> public void initialize() throws HBaseIOException{<a name="line.1528"></a>
-<span class="sourceLineNo">1529</span> }<a name="line.1529"></a>
-<span class="sourceLineNo">1530</span><a name="line.1530"></a>
-<span class="sourceLineNo">1531</span> @Override<a name="line.1531"></a>
-<span class="sourceLineNo">1532</span> public void regionOnline(RegionInfo regionInfo, ServerName sn) {<a name="line.1532"></a>
-<span class="sourceLineNo">1533</span> }<a name="line.1533"></a>
-<span class="sourceLineNo">1534</span><a name="line.1534"></a>
-<span class="sourceLineNo">1535</span> @Override<a name="line.1535"></a>
-<span class="sourceLineNo">1536</span> public void regionOffline(RegionInfo regionInfo) {<a name="line.1536"></a>
-<span class="sourceLineNo">1537</span> }<a name="line.1537"></a>
-<span class="sourceLineNo">1538</span><a name="line.1538"></a>
-<span class="sourceLineNo">1539</span> @Override<a name="line.1539"></a>
-<span class="sourceLineNo">1540</span> public boolean isStopped() {<a name="line.1540"></a>
-<span class="sourceLineNo">1541</span> return stopped;<a name="line.1541"></a>
+<span class="sourceLineNo">1527</span> LOG.info("Reassigned " + regions.size() + " regions. " + numRetainedAssigments<a name="line.1527"></a>
+<span class="sourceLineNo">1528</span> + " retained the pre-restart assignment. " + randomAssignMsg);<a name="line.1528"></a>
+<span class="sourceLineNo">1529</span> return assignments;<a name="line.1529"></a>
+<span class="sourceLineNo">1530</span> }<a name="line.1530"></a>
+<span class="sourceLineNo">1531</span><a name="line.1531"></a>
+<span class="sourceLineNo">1532</span> @Override<a name="line.1532"></a>
+<span class="sourceLineNo">1533</span> public void initialize() throws HBaseIOException{<a name="line.1533"></a>
+<span class="sourceLineNo">1534</span> }<a name="line.1534"></a>
+<span class="sourceLineNo">1535</span><a name="line.1535"></a>
+<span class="sourceLineNo">1536</span> @Override<a name="line.1536"></a>
+<span class="sourceLineNo">1537</span> public void regionOnline(RegionInfo regionInfo, ServerName sn) {<a name="line.1537"></a>
+<span class="sourceLineNo">1538</span> }<a name="line.1538"></a>
+<span class="sourceLineNo">1539</span><a name="line.1539"></a>
+<span class="sourceLineNo">1540</span> @Override<a name="line.1540"></a>
+<span class="sourceLineNo">1541</span> public void regionOffline(RegionInfo regionInfo) {<a name="line.1541"></a>
<span class="sourceLineNo">1542</span> }<a name="line.1542"></a>
<span class="sourceLineNo">1543</span><a name="line.1543"></a>
<span class="sourceLineNo">1544</span> @Override<a name="line.1544"></a>
-<span class="sourceLineNo">1545</span> public void stop(String why) {<a name="line.1545"></a>
-<span class="sourceLineNo">1546</span> LOG.info("Load Balancer stop requested: "+why);<a name="line.1546"></a>
-<span class="sourceLineNo">1547</span> stopped = true;<a name="line.1547"></a>
-<span class="sourceLineNo">1548</span> }<a name="line.1548"></a>
-<span class="sourceLineNo">1549</span><a name="line.1549"></a>
-<span class="sourceLineNo">1550</span> /**<a name="line.1550"></a>
-<span class="sourceLineNo">1551</span> * Used to assign a single region to a random server.<a name="line.1551"></a>
-<span class="sourceLineNo">1552</span> */<a name="line.1552"></a>
-<span class="sourceLineNo">1553</span> private ServerName randomAssignment(Cluster cluster, RegionInfo regionInfo,<a name="line.1553"></a>
-<span class="sourceLineNo">1554</span> List<ServerName> servers) {<a name="line.1554"></a>
-<span class="sourceLineNo">1555</span> int numServers = servers.size(); // servers is not null, numServers > 1<a name="line.1555"></a>
-<span class="sourceLineNo">1556</span> ServerName sn = null;<a name="line.1556"></a>
-<span class="sourceLineNo">1557</span> final int maxIterations = numServers * 4;<a name="line.1557"></a>
-<span class="sourceLineNo">1558</span> int iterations = 0;<a name="line.1558"></a>
-<span class="sourceLineNo">1559</span> List<ServerName> usedSNs = new ArrayList<>(servers.size());<a name="line.1559"></a>
-<span class="sourceLineNo">1560</span> do {<a name="line.1560"></a>
-<span class="sourceLineNo">1561</span> int i = RANDOM.nextInt(numServers);<a name="line.1561"></a>
-<span class="sourceLineNo">1562</span> sn = servers.get(i);<a name="line.1562"></a>
-<span class="sourceLineNo">1563</span> if (!usedSNs.contains(sn)) {<a name="line.1563"></a>
-<span class="sourceLineNo">1564</span> usedSNs.add(sn);<a name="line.1564"></a>
-<span class="sourceLineNo">1565</span> }<a name="line.1565"></a>
-<span class="sourceLineNo">1566</span> } while (cluster.wouldLowerAvailability(regionInfo, sn)<a name="line.1566"></a>
-<span class="sourceLineNo">1567</span> && iterations++ < maxIterations);<a name="line.1567"></a>
-<span class="sourceLineNo">1568</span> if (iterations >= maxIterations) {<a name="line.1568"></a>
-<span class="sourceLineNo">1569</span> // We have reached the max. Means the servers that we collected is still lowering the<a name="line.1569"></a>
-<span class="sourceLineNo">1570</span> // availability<a name="line.1570"></a>
-<span class="sourceLineNo">1571</span> for (ServerName unusedServer : servers) {<a name="line.1571"></a>
-<span class="sourceLineNo">1572</span> if (!usedSNs.contains(unusedServer)) {<a name="line.1572"></a>
-<span class="sourceLineNo">1573</span> // check if any other unused server is there for us to use.<a name="line.1573"></a>
-<span class="sourceLineNo">1574</span> // If so use it. Else we have not other go but to go with one of them<a name="line.1574"></a>
-<span class="sourceLineNo">1575</span> if (!cluster.wouldLowerAvailability(regionInfo, unusedServer)) {<a name="line.1575"></a>
-<span class="sourceLineNo">1576</span> sn = unusedServer;<a name="line.1576"></a>
-<span class="sourceLineNo">1577</span> break;<a name="line.1577"></a>
-<span class="sourceLineNo">1578</span> }<a name="line.1578"></a>
-<span class="sourceLineNo">1579</span> }<a name="line.1579"></a>
-<span class="sourceLineNo">1580</span> }<a name="line.1580"></a>
-<span class="sourceLineNo">1581</span> }<a name="line.1581"></a>
-<span class="sourceLineNo">1582</span> cluster.doAssignRegion(regionInfo, sn);<a name="line.1582"></a>
-<span class="sourceLineNo">1583</span> return sn;<a name="line.1583"></a>
-<span class="sourceLineNo">1584</span> }<a name="line.1584"></a>
-<span class="sourceLineNo">1585</span><a name="line.1585"></a>
-<span class="sourceLineNo">1586</span> /**<a name="line.1586"></a>
-<span class="sourceLineNo">1587</span> * Round robin a list of regions to a list of servers<a name="line.1587"></a>
-<span class="sourceLineNo">1588</span> */<a name="line.1588"></a>
-<span class="sourceLineNo">1589</span> private void roundRobinAssignment(Cluster cluster, List<RegionInfo> regions,<a name="line.1589"></a>
-<span class="sourceLineNo">1590</span> List<RegionInfo> unassignedRegions, List<ServerName> servers,<a name="line.1590"></a>
-<span class="sourceLineNo">1591</span> Map<ServerName, List<RegionInfo>> assignments) {<a name="line.1591"></a>
-<span class="sourceLineNo">1592</span><a name="line.1592"></a>
-<span class="sourceLineNo">1593</span> int numServers = servers.size();<a name="line.1593"></a>
-<span class="sourceLineNo">1594</span> int numRegions = regions.size();<a name="line.1594"></a>
-<span class="sourceLineNo">1595</span> int max = (int) Math.ceil((float) numRegions / numServers);<a name="line.1595"></a>
-<span class="sourceLineNo">1596</span> int serverIdx = 0;<a name="line.1596"></a>
-<span class="sourceLineNo">1597</span> if (numServers > 1) {<a name="line.1597"></a>
-<span class="sourceLineNo">1598</span> serverIdx = RANDOM.nextInt(numServers);<a name="line.1598"></a>
-<span class="sourceLineNo">1599</span> }<a name="line.1599"></a>
-<span class="sourceLineNo">1600</span> int regionIdx = 0;<a name="line.1600"></a>
-<span class="sourceLineNo">1601</span><a name="line.1601"></a>
-<span class="sourceLineNo">1602</span> for (int j = 0; j < numServers; j++) {<a name="line.1602"></a>
-<span class="sourceLineNo">1603</span> ServerName server = servers.get((j + serverIdx) % numServers);<a name="line.1603"></a>
-<span class="sourceLineNo">1604</span> List<RegionInfo> serverRegions = new ArrayList<>(max);<a name="line.1604"></a>
-<span class="sourceLineNo">1605</span> for (int i = regionIdx; i < numRegions; i += numServers) {<a name="line.1605"></a>
-<span class="sourceLineNo">1606</span> RegionInfo region = regions.get(i % numRegions);<a name="line.1606"></a>
-<span class="sourceLineNo">1607</span> if (cluster.wouldLowerAvailability(region, server)) {<a name="line.1607"></a>
-<span class="sourceLineNo">1608</span> unassignedRegions.add(region);<a name="line.1608"></a>
-<span class="sourceLineNo">1609</span> } else {<a name="line.1609"></a>
-<span class="sourceLineNo">1610</span> serverRegions.add(region);<a name="line.1610"></a>
-<span class="sourceLineNo">1611</span> cluster.doAssignRegion(region, server);<a name="line.1611"></a>
-<span class="sourceLineNo">1612</span> }<a name="line.1612"></a>
-<span class="sourceLineNo">1613</span> }<a name="line.1613"></a>
-<span class="sourceLineNo">1614</span> assignments.put(server, serverRegions);<a name="line.1614"></a>
-<span class="sourceLineNo">1615</span> regionIdx++;<a name="line.1615"></a>
-<span class="sourceLineNo">1616</span> }<a name="line.1616"></a>
-<span class="sourceLineNo">1617</span> }<a name="line.1617"></a>
-<span class="sourceLineNo">1618</span><a name="line.1618"></a>
-<span class="sourceLineNo">1619</span> protected Map<ServerName, List<RegionInfo>> getRegionAssignmentsByServer(<a name="line.1619"></a>
-<span class="sourceLineNo">1620</span> Collection<RegionInfo> regions) {<a name="line.1620"></a>
-<span class="sourceLineNo">1621</span> if (this.services != null && this.services.getAssignmentManager() != null) {<a name="line.1621"></a>
-<span class="sourceLineNo">1622</span> return this.services.getAssignmentManager().getSnapShotOfAssignment(regions);<a name="line.1622"></a>
-<span class="sourceLineNo">1623</span> } else {<a name="line.1623"></a>
-<span class="sourceLineNo">1624</span> return new HashMap<>();<a name="line.1624"></a>
-<span class="sourceLineNo">1625</span> }<a name="line.1625"></a>
-<span class="sourceLineNo">1626</span> }<a name="line.1626"></a>
-<span class="sourceLineNo">1627</span><a name="line.1627"></a>
-<span class="sourceLineNo">1628</span> @Override<a name="line.1628"></a>
-<span class="sourceLineNo">1629</span> public void onConfigurationChange(Configuration conf) {<a name="line.1629"></a>
-<span class="sourceLineNo">1630</span> }<a name="line.1630"></a>
-<span class="sourceLineNo">1631</span>}<a name="line.1631"></a>
+<span class="sourceLineNo">1545</span> public boolean isStopped() {<a name="line.1545"></a>
+<span class="sourceLineNo">1546</span> return stopped;<a name="line.1546"></a>
+<span class="sourceLineNo">1547</span> }<a name="line.1547"></a>
+<span class="sourceLineNo">1548</span><a name="line.1548"></a>
+<span class="sourceLineNo">1549</span> @Override<a name="line.1549"></a>
+<span class="sourceLineNo">1550</span> public void stop(String why) {<a name="line.1550"></a>
+<span class="sourceLineNo">1551</span> LOG.info("Load Balancer stop requested: "+why);<a name="line.1551"></a>
+<span class="sourceLineNo">1552</span> stopped = true;<a name="line.1552"></a>
+<span class="sourceLineNo">1553</span> }<a name="line.1553"></a>
+<span class="sourceLineNo">1554</span><a name="line.1554"></a>
+<span class="sourceLineNo">1555</span> /**<a name="line.1555"></a>
+<span class="sourceLineNo">1556</span> * Used to assign a single region to a random server.<a name="line.1556"></a>
+<span class="sourceLineNo">1557</span> */<a name="line.1557"></a>
+<span class="sourceLineNo">1558</span> private ServerName randomAssignment(Cluster cluster, RegionInfo regionInfo,<a name="line.1558"></a>
+<span class="sourceLineNo">1559</span> List<ServerName> servers) {<a name="line.1559"></a>
+<span class="sourceLineNo">1560</span> int numServers = servers.size(); // servers is not null, numServers > 1<a name="line.1560"></a>
+<span class="sourceLineNo">1561</span> ServerName sn = null;<a name="line.1561"></a>
+<span class="sourceLineNo">1562</span> final int maxIterations = numServers * 4;<a name="line.1562"></a>
+<span class="sourceLineNo">1563</span> int iterations = 0;<a name="line.1563"></a>
+<span class="sourceLineNo">1564</span> List<ServerName> usedSNs = new ArrayList<>(servers.size());<a name="line.1564"></a>
+<span class="sourceLineNo">1565</span> do {<a name="line.1565"></a>
+<span class="sourceLineNo">1566</span> int i = RANDOM.nextInt(numServers);<a name="line.1566"></a>
+<span class="sourceLineNo">1567</span> sn = servers.get(i);<a name="line.1567"></a>
+<span class="sourceLineNo">1568</span> if (!usedSNs.contains(sn)) {<a name="line.1568"></a>
+<span class="sourceLineNo">1569</span> usedSNs.add(sn);<a name="line.1569"></a>
+<span class="sourceLineNo">1570</span> }<a name="line.1570"></a>
+<span class="sourceLineNo">1571</span> } while (cluster.wouldLowerAvailability(regionInfo, sn)<a name="line.1571"></a>
+<span class="sourceLineNo">1572</span> && iterations++ < maxIterations);<a name="line.1572"></a>
+<span class="sourceLineNo">1573</span> if (iterations >= maxIterations) {<a name="line.1573"></a>
+<span class="sourceLineNo">1574</span> // We have reached the max. Means the servers that we collected is still lowering the<a name="line.1574"></a>
+<span class="sourceLineNo">1575</span> // availability<a name="line.1575"></a>
+<span class="sourceLineNo">1576</span> for (ServerName unusedServer : servers) {<a name="line.1576"></a>
+<span class="sourceLineNo">1577</span> if (!usedSNs.contains(unusedServer)) {<a name="line.1577"></a>
+<span class="sourceLineNo">1578</span> // check if any other unused server is there for us to use.<a name="line.1578"></a>
+<span class="sourceLineNo">1579</span> // If so use it. Else we have not other go but to go with one of them<a name="line.1579"></a>
+<span class="sourceLineNo">1580</span> if (!cluster.wouldLowerAvailability(regionInfo, unusedServer)) {<a name="line.1580"></a>
+<span class="sourceLineNo">1581</span> sn = unusedServer;<a name="line.1581"></a>
+<span class="sourceLineNo">1582</span> break;<a name="line.1582"></a>
+<span class="sourceLineNo">1583</span> }<a name="line.1583"></a>
+<span class="sourceLineNo">1584</span> }<a name="line.1584"></a>
+<span class="sourceLineNo">1585</span> }<a name="line.1585"></a>
+<span class="sourceLineNo">1586</span> }<a name="line.1586"></a>
+<span class="sourceLineNo">1587</span> cluster.doAssignRegion(regionInfo, sn);<a name="line.1587"></a>
+<span class="sourceLineNo">1588</span> return sn;<a name="line.1588"></a>
+<span class="sourceLineNo">1589</span> }<a name="line.1589"></a>
+<span class="sourceLineNo">1590</span><a name="line.1590"></a>
+<span class="sourceLineNo">1591</span> /**<a name="line.1591"></a>
+<span class="sourceLineNo">1592</span> * Round robin a list of regions to a list of servers<a name="line.1592"></a>
+<span class="sourceLineNo">1593</span> */<a name="line.1593"></a>
+<span class="sourceLineNo">1594</span> private void roundRobinAssignment(Cluster cluster, List<RegionInfo> regions,<a name="line.1594"></a>
+<span class="sourceLineNo">1595</span> List<RegionInfo> unassignedRegions, List<ServerName> servers,<a name="line.1595"></a>
+<span class="sourceLineNo">1596</span> Map<ServerName, List<RegionInfo>> assignments) {<a name="line.1596"></a>
+<span class="sourceLineNo">1597</span><a name="line.1597"></a>
+<span class="sourceLineNo">1598</span> int numServers = servers.size();<a name="line.1598"></a>
+<span class="sourceLineNo">1599</span> int numRegions = regions.size();<a name="line.1599"></a>
+<span class="sourceLineNo">1600</span> int max = (int) Math.ceil((float) numRegions / numServers);<a name="line.1600"></a>
+<span class="sourceLineNo">1601</span> int serverIdx = 0;<a name="line.1601"></a>
+<span class="sourceLineNo">1602</span> if (numServers > 1) {<a name="line.1602"></a>
+<span class="sourceLineNo">1603</span> serverIdx = RANDOM.nextInt(numServers);<a name="line.1603"></a>
+<span class="sourceLineNo">1604</span> }<a name="line.1604"></a>
+<span class="sourceLineNo">1605</span> int regionIdx = 0;<a name="line.1605"></a>
+<span class="sourceLineNo">1606</span><a name="line.1606"></a>
+<span class="sourceLineNo">1607</span> for (int j = 0; j < numServers; j++) {<a name="line.1607"></a>
+<span class="sourceLineNo">1608</span> ServerName server = servers.get((j + serverIdx) % numServers);<a name="line.1608"></a>
+<span class="sourceLineNo">1609</span> List<RegionInfo> serverRegions = new ArrayList<>(max);<a name="line.1609"></a>
+<span class="sourceLineNo">1610</span> for (int i = regionIdx; i < numRegions; i += numServers) {<a name="line.1610"></a>
+<span class="sourceLineNo">1611</span> RegionInfo region = regions.get(i % numRegions);<a name="line.1611"></a>
+<span class="sourceLineNo">1612</span> if (cluster.wouldLowerAvailability(region, server)) {<a name="line.1612"></a>
+<span class="sourceLineNo">1613</span> unassignedRegions.add(region);<a name="line.1613"></a>
+<span class="sourceLineNo">1614</span> } else {<a name="line.1614"></a>
+<span class="sourceLineNo">1615</span> serverRegions.add(region);<a name="line.1615"></a>
+<span class="sourceLineNo">1616</span> cluster.doAssignRegion(region, server);<a name="line.1616"></a>
+<span class="sourceLineNo">1617</span> }<a name="line.1617"></a>
+<span class="sourceLineNo">1618</span> }<a name="line.1618"></a>
+<span class="sourceLineNo">1619</span> assignments.put(server, serverRegions);<a name="line.1619"></a>
+<span class="sourceLineNo">1620</span> regionIdx++;<a name="line.1620"></a>
+<span class="sourceLineNo">1621</span> }<a name="line.1621"></a>
+<span class="sourceLineNo">1622</span> }<a name="line.1622"></a>
+<span class="sourceLineNo">1623</span><a name="line.1623"></a>
+<span class="sourceLineNo">1624</span> protected Map<ServerName, List<RegionInfo>> getRegionAssignmentsByServer(<a name="line.1624"></a>
+<span class="sourceLineNo">1625</span> Collection<RegionInfo> regions) {<a name="line.1625"></a>
+<span class="sourceLineNo">1626</span> if (this.services != null && this.services.getAssignmentManager() != null) {<a name="line.1626"></a>
+<span class="sourceLineNo">1627</span> return this.services.getAssignmentManager().getSnapShotOfAssignment(regions);<a name="line.1627"></a>
+<span class="sourceLineNo">1628</span> } else {<a name="line.1628"></a>
+<span class="sourceLineNo">1629</span> return new HashMap<>();<a name="line.1629"></a>
+<span class="sourceLineNo">1630</span> }<a name="line.1630"></a>
+<span class="sourceLineNo">1631</span> }<a name="line.1631"></a>
+<span class="sourceLineNo">1632</span><a name="line.1632"></a>
+<span class="sourceLineNo">1633</span> @Override<a name="line.1633"></a>
+<span class="sourceLineNo">1634</span> public void onConfigurationChange(Configuration conf) {<a name="line.1634"></a>
+<span class="sourceLineNo">1635</span> }<a name="line.1635"></a>
+<span class="sourceLineNo">1636</span>}<a name="line.1636"></a>