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/05/10 14:48:25 UTC
[25/34] hbase-site git commit: Published site at
8ba2a7eeb967a80d04020e30b2fe8e8652ea1758.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/15a025c1/devapidocs/src-html/org/apache/hadoop/hbase/master/balancer/BaseLoadBalancer.Cluster.Action.html
----------------------------------------------------------------------
diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/master/balancer/BaseLoadBalancer.Cluster.Action.html b/devapidocs/src-html/org/apache/hadoop/hbase/master/balancer/BaseLoadBalancer.Cluster.Action.html
index 7e3039a..65b5edb 100644
--- a/devapidocs/src-html/org/apache/hadoop/hbase/master/balancer/BaseLoadBalancer.Cluster.Action.html
+++ b/devapidocs/src-html/org/apache/hadoop/hbase/master/balancer/BaseLoadBalancer.Cluster.Action.html
@@ -1421,155 +1421,172 @@
<span class="sourceLineNo">1413</span> // after the cluster restart.<a name="line.1413"></a>
<span class="sourceLineNo">1414</span> Set<String> oldHostsNoLongerPresent = Sets.newTreeSet();<a name="line.1414"></a>
<span class="sourceLineNo">1415</span><a name="line.1415"></a>
-<span class="sourceLineNo">1416</span> int numRandomAssignments = 0;<a name="line.1416"></a>
-<span class="sourceLineNo">1417</span> int numRetainedAssigments = 0;<a name="line.1417"></a>
+<span class="sourceLineNo">1416</span> // If the old servers aren't present, lets assign those regions later.<a name="line.1416"></a>
+<span class="sourceLineNo">1417</span> List<RegionInfo> randomAssignRegions = Lists.newArrayList();<a name="line.1417"></a>
<span class="sourceLineNo">1418</span><a name="line.1418"></a>
-<span class="sourceLineNo">1419</span> Cluster cluster = createCluster(servers, regions.keySet(), true);<a name="line.1419"></a>
-<span class="sourceLineNo">1420</span><a name="line.1420"></a>
-<span class="sourceLineNo">1421</span> for (Map.Entry<RegionInfo, ServerName> entry : regions.entrySet()) {<a name="line.1421"></a>
-<span class="sourceLineNo">1422</span> RegionInfo region = entry.getKey();<a name="line.1422"></a>
-<span class="sourceLineNo">1423</span> ServerName oldServerName = entry.getValue();<a name="line.1423"></a>
-<span class="sourceLineNo">1424</span> List<ServerName> localServers = new ArrayList<>();<a name="line.1424"></a>
-<span class="sourceLineNo">1425</span> if (oldServerName != null) {<a name="line.1425"></a>
-<span class="sourceLineNo">1426</span> localServers = serversByHostname.get(oldServerName.getHostname());<a name="line.1426"></a>
-<span class="sourceLineNo">1427</span> }<a name="line.1427"></a>
-<span class="sourceLineNo">1428</span> if (localServers.isEmpty()) {<a name="line.1428"></a>
-<span class="sourceLineNo">1429</span> // No servers on the new cluster match up with this hostname,<a name="line.1429"></a>
-<span class="sourceLineNo">1430</span> // assign randomly.<a name="line.1430"></a>
-<span class="sourceLineNo">1431</span> ServerName randomServer = randomAssignment(cluster, region, servers);<a name="line.1431"></a>
-<span class="sourceLineNo">1432</span> assignments.get(randomServer).add(region);<a name="line.1432"></a>
-<span class="sourceLineNo">1433</span> numRandomAssignments++;<a name="line.1433"></a>
-<span class="sourceLineNo">1434</span> if (oldServerName != null) oldHostsNoLongerPresent.add(oldServerName.getHostname());<a name="line.1434"></a>
-<span class="sourceLineNo">1435</span> } else if (localServers.size() == 1) {<a name="line.1435"></a>
-<span class="sourceLineNo">1436</span> // the usual case - one new server on same host<a name="line.1436"></a>
-<span class="sourceLineNo">1437</span> ServerName target = localServers.get(0);<a name="line.1437"></a>
-<span class="sourceLineNo">1438</span> assignments.get(target).add(region);<a name="line.1438"></a>
-<span class="sourceLineNo">1439</span> cluster.doAssignRegion(region, target);<a name="line.1439"></a>
-<span class="sourceLineNo">1440</span> numRetainedAssigments++;<a name="line.1440"></a>
-<span class="sourceLineNo">1441</span> } else {<a name="line.1441"></a>
-<span class="sourceLineNo">1442</span> // multiple new servers in the cluster on this same host<a name="line.1442"></a>
-<span class="sourceLineNo">1443</span> if (localServers.contains(oldServerName)) {<a name="line.1443"></a>
-<span class="sourceLineNo">1444</span> assignments.get(oldServerName).add(region);<a name="line.1444"></a>
-<span class="sourceLineNo">1445</span> cluster.doAssignRegion(region, oldServerName);<a name="line.1445"></a>
-<span class="sourceLineNo">1446</span> } else {<a name="line.1446"></a>
-<span class="sourceLineNo">1447</span> ServerName target = null;<a name="line.1447"></a>
-<span class="sourceLineNo">1448</span> for (ServerName tmp: localServers) {<a name="line.1448"></a>
-<span class="sourceLineNo">1449</span> if (tmp.getPort() == oldServerName.getPort()) {<a name="line.1449"></a>
-<span class="sourceLineNo">1450</span> target = tmp;<a name="line.1450"></a>
-<span class="sourceLineNo">1451</span> break;<a name="line.1451"></a>
-<span class="sourceLineNo">1452</span> }<a name="line.1452"></a>
-<span class="sourceLineNo">1453</span> }<a name="line.1453"></a>
-<span class="sourceLineNo">1454</span> if (target == null) {<a name="line.1454"></a>
-<span class="sourceLineNo">1455</span> target = randomAssignment(cluster, region, localServers);<a name="line.1455"></a>
+<span class="sourceLineNo">1419</span> int numRandomAssignments = 0;<a name="line.1419"></a>
+<span class="sourceLineNo">1420</span> int numRetainedAssigments = 0;<a name="line.1420"></a>
+<span class="sourceLineNo">1421</span><a name="line.1421"></a>
+<span class="sourceLineNo">1422</span> Cluster cluster = createCluster(servers, regions.keySet(), true);<a name="line.1422"></a>
+<span class="sourceLineNo">1423</span><a name="line.1423"></a>
+<span class="sourceLineNo">1424</span> for (Map.Entry<RegionInfo, ServerName> entry : regions.entrySet()) {<a name="line.1424"></a>
+<span class="sourceLineNo">1425</span> RegionInfo region = entry.getKey();<a name="line.1425"></a>
+<span class="sourceLineNo">1426</span> ServerName oldServerName = entry.getValue();<a name="line.1426"></a>
+<span class="sourceLineNo">1427</span> List<ServerName> localServers = new ArrayList<>();<a name="line.1427"></a>
+<span class="sourceLineNo">1428</span> if (oldServerName != null) {<a name="line.1428"></a>
+<span class="sourceLineNo">1429</span> localServers = serversByHostname.get(oldServerName.getHostname());<a name="line.1429"></a>
+<span class="sourceLineNo">1430</span> }<a name="line.1430"></a>
+<span class="sourceLineNo">1431</span> if (localServers.isEmpty()) {<a name="line.1431"></a>
+<span class="sourceLineNo">1432</span> // No servers on the new cluster match up with this hostname, assign randomly, later.<a name="line.1432"></a>
+<span class="sourceLineNo">1433</span> randomAssignRegions.add(region);<a name="line.1433"></a>
+<span class="sourceLineNo">1434</span> if (oldServerName != null) {<a name="line.1434"></a>
+<span class="sourceLineNo">1435</span> oldHostsNoLongerPresent.add(oldServerName.getHostname());<a name="line.1435"></a>
+<span class="sourceLineNo">1436</span> }<a name="line.1436"></a>
+<span class="sourceLineNo">1437</span> } else if (localServers.size() == 1) {<a name="line.1437"></a>
+<span class="sourceLineNo">1438</span> // the usual case - one new server on same host<a name="line.1438"></a>
+<span class="sourceLineNo">1439</span> ServerName target = localServers.get(0);<a name="line.1439"></a>
+<span class="sourceLineNo">1440</span> assignments.get(target).add(region);<a name="line.1440"></a>
+<span class="sourceLineNo">1441</span> numRetainedAssigments++;<a name="line.1441"></a>
+<span class="sourceLineNo">1442</span> } else {<a name="line.1442"></a>
+<span class="sourceLineNo">1443</span> // multiple new servers in the cluster on this same host<a name="line.1443"></a>
+<span class="sourceLineNo">1444</span> if (localServers.contains(oldServerName)) {<a name="line.1444"></a>
+<span class="sourceLineNo">1445</span> assignments.get(oldServerName).add(region);<a name="line.1445"></a>
+<span class="sourceLineNo">1446</span> numRetainedAssigments++;<a name="line.1446"></a>
+<span class="sourceLineNo">1447</span> } else {<a name="line.1447"></a>
+<span class="sourceLineNo">1448</span> ServerName target = null;<a name="line.1448"></a>
+<span class="sourceLineNo">1449</span> for (ServerName tmp : localServers) {<a name="line.1449"></a>
+<span class="sourceLineNo">1450</span> if (tmp.getPort() == oldServerName.getPort()) {<a name="line.1450"></a>
+<span class="sourceLineNo">1451</span> target = tmp;<a name="line.1451"></a>
+<span class="sourceLineNo">1452</span> assignments.get(tmp).add(region);<a name="line.1452"></a>
+<span class="sourceLineNo">1453</span> numRetainedAssigments++;<a name="line.1453"></a>
+<span class="sourceLineNo">1454</span> break;<a name="line.1454"></a>
+<span class="sourceLineNo">1455</span> }<a name="line.1455"></a>
<span class="sourceLineNo">1456</span> }<a name="line.1456"></a>
-<span class="sourceLineNo">1457</span> assignments.get(target).add(region);<a name="line.1457"></a>
-<span class="sourceLineNo">1458</span> }<a name="line.1458"></a>
-<span class="sourceLineNo">1459</span> numRetainedAssigments++;<a name="line.1459"></a>
-<span class="sourceLineNo">1460</span> }<a name="line.1460"></a>
-<span class="sourceLineNo">1461</span> }<a name="line.1461"></a>
-<span class="sourceLineNo">1462</span><a name="line.1462"></a>
-<span class="sourceLineNo">1463</span> String randomAssignMsg = "";<a name="line.1463"></a>
-<span class="sourceLineNo">1464</span> if (numRandomAssignments > 0) {<a name="line.1464"></a>
-<span class="sourceLineNo">1465</span> randomAssignMsg =<a name="line.1465"></a>
-<span class="sourceLineNo">1466</span> numRandomAssignments + " regions were assigned "<a name="line.1466"></a>
-<span class="sourceLineNo">1467</span> + "to random hosts, since the old hosts for these regions are no "<a name="line.1467"></a>
-<span class="sourceLineNo">1468</span> + "longer present in the cluster. These hosts were:\n "<a name="line.1468"></a>
-<span class="sourceLineNo">1469</span> + Joiner.on("\n ").join(oldHostsNoLongerPresent);<a name="line.1469"></a>
-<span class="sourceLineNo">1470</span> }<a name="line.1470"></a>
-<span class="sourceLineNo">1471</span><a name="line.1471"></a>
-<span class="sourceLineNo">1472</span> LOG.info("Reassigned " + regions.size() + " regions. " + numRetainedAssigments<a name="line.1472"></a>
-<span class="sourceLineNo">1473</span> + " retained the pre-restart assignment. " + randomAssignMsg);<a name="line.1473"></a>
-<span class="sourceLineNo">1474</span> return assignments;<a name="line.1474"></a>
-<span class="sourceLineNo">1475</span> }<a name="line.1475"></a>
-<span class="sourceLineNo">1476</span><a name="line.1476"></a>
-<span class="sourceLineNo">1477</span> @Override<a name="line.1477"></a>
-<span class="sourceLineNo">1478</span> public void initialize() throws HBaseIOException{<a name="line.1478"></a>
-<span class="sourceLineNo">1479</span> }<a name="line.1479"></a>
-<span class="sourceLineNo">1480</span><a name="line.1480"></a>
-<span class="sourceLineNo">1481</span> @Override<a name="line.1481"></a>
-<span class="sourceLineNo">1482</span> public void regionOnline(RegionInfo regionInfo, ServerName sn) {<a name="line.1482"></a>
-<span class="sourceLineNo">1483</span> }<a name="line.1483"></a>
-<span class="sourceLineNo">1484</span><a name="line.1484"></a>
-<span class="sourceLineNo">1485</span> @Override<a name="line.1485"></a>
-<span class="sourceLineNo">1486</span> public void regionOffline(RegionInfo regionInfo) {<a name="line.1486"></a>
-<span class="sourceLineNo">1487</span> }<a name="line.1487"></a>
+<span class="sourceLineNo">1457</span> if (target == null) {<a name="line.1457"></a>
+<span class="sourceLineNo">1458</span> randomAssignRegions.add(region);<a name="line.1458"></a>
+<span class="sourceLineNo">1459</span> }<a name="line.1459"></a>
+<span class="sourceLineNo">1460</span> }<a name="line.1460"></a>
+<span class="sourceLineNo">1461</span> }<a name="line.1461"></a>
+<span class="sourceLineNo">1462</span> }<a name="line.1462"></a>
+<span class="sourceLineNo">1463</span><a name="line.1463"></a>
+<span class="sourceLineNo">1464</span> // If servers from prior assignment aren't present, then lets do randomAssignment on regions.<a name="line.1464"></a>
+<span class="sourceLineNo">1465</span> if (randomAssignRegions.size() > 0) {<a name="line.1465"></a>
+<span class="sourceLineNo">1466</span> for (Map.Entry<ServerName, List<RegionInfo>> entry : assignments.entrySet()) {<a name="line.1466"></a>
+<span class="sourceLineNo">1467</span> ServerName sn = entry.getKey();<a name="line.1467"></a>
+<span class="sourceLineNo">1468</span> for (RegionInfo region : entry.getValue()) {<a name="line.1468"></a>
+<span class="sourceLineNo">1469</span> cluster.doAssignRegion(region, sn);<a name="line.1469"></a>
+<span class="sourceLineNo">1470</span> }<a name="line.1470"></a>
+<span class="sourceLineNo">1471</span> }<a name="line.1471"></a>
+<span class="sourceLineNo">1472</span> for (RegionInfo region : randomAssignRegions) {<a name="line.1472"></a>
+<span class="sourceLineNo">1473</span> ServerName target = randomAssignment(cluster, region, servers);<a name="line.1473"></a>
+<span class="sourceLineNo">1474</span> assignments.get(target).add(region);<a name="line.1474"></a>
+<span class="sourceLineNo">1475</span> cluster.doAssignRegion(region, target);<a name="line.1475"></a>
+<span class="sourceLineNo">1476</span> numRandomAssignments++;<a name="line.1476"></a>
+<span class="sourceLineNo">1477</span> }<a name="line.1477"></a>
+<span class="sourceLineNo">1478</span> }<a name="line.1478"></a>
+<span class="sourceLineNo">1479</span><a name="line.1479"></a>
+<span class="sourceLineNo">1480</span> String randomAssignMsg = "";<a name="line.1480"></a>
+<span class="sourceLineNo">1481</span> if (numRandomAssignments > 0) {<a name="line.1481"></a>
+<span class="sourceLineNo">1482</span> randomAssignMsg =<a name="line.1482"></a>
+<span class="sourceLineNo">1483</span> numRandomAssignments + " regions were assigned "<a name="line.1483"></a>
+<span class="sourceLineNo">1484</span> + "to random hosts, since the old hosts for these regions are no "<a name="line.1484"></a>
+<span class="sourceLineNo">1485</span> + "longer present in the cluster. These hosts were:\n "<a name="line.1485"></a>
+<span class="sourceLineNo">1486</span> + Joiner.on("\n ").join(oldHostsNoLongerPresent);<a name="line.1486"></a>
+<span class="sourceLineNo">1487</span> }<a name="line.1487"></a>
<span class="sourceLineNo">1488</span><a name="line.1488"></a>
-<span class="sourceLineNo">1489</span> @Override<a name="line.1489"></a>
-<span class="sourceLineNo">1490</span> public boolean isStopped() {<a name="line.1490"></a>
-<span class="sourceLineNo">1491</span> return stopped;<a name="line.1491"></a>
+<span class="sourceLineNo">1489</span> LOG.info("Reassigned " + regions.size() + " regions. " + numRetainedAssigments<a name="line.1489"></a>
+<span class="sourceLineNo">1490</span> + " retained the pre-restart assignment. " + randomAssignMsg);<a name="line.1490"></a>
+<span class="sourceLineNo">1491</span> return assignments;<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> @Override<a name="line.1494"></a>
-<span class="sourceLineNo">1495</span> public void stop(String why) {<a name="line.1495"></a>
-<span class="sourceLineNo">1496</span> LOG.info("Load Balancer stop requested: "+why);<a name="line.1496"></a>
-<span class="sourceLineNo">1497</span> stopped = true;<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> * Used to assign a single region to a random server.<a name="line.1501"></a>
-<span class="sourceLineNo">1502</span> */<a name="line.1502"></a>
-<span class="sourceLineNo">1503</span> private ServerName randomAssignment(Cluster cluster, RegionInfo regionInfo,<a name="line.1503"></a>
-<span class="sourceLineNo">1504</span> List<ServerName> servers) {<a name="line.1504"></a>
-<span class="sourceLineNo">1505</span> int numServers = servers.size(); // servers is not null, numServers > 1<a name="line.1505"></a>
-<span class="sourceLineNo">1506</span> ServerName sn = null;<a name="line.1506"></a>
-<span class="sourceLineNo">1507</span> final int maxIterations = numServers * 4;<a name="line.1507"></a>
-<span class="sourceLineNo">1508</span> int iterations = 0;<a name="line.1508"></a>
-<span class="sourceLineNo">1509</span><a name="line.1509"></a>
-<span class="sourceLineNo">1510</span> do {<a name="line.1510"></a>
-<span class="sourceLineNo">1511</span> int i = RANDOM.nextInt(numServers);<a name="line.1511"></a>
-<span class="sourceLineNo">1512</span> sn = servers.get(i);<a name="line.1512"></a>
-<span class="sourceLineNo">1513</span> } while (cluster.wouldLowerAvailability(regionInfo, sn)<a name="line.1513"></a>
-<span class="sourceLineNo">1514</span> && iterations++ < maxIterations);<a name="line.1514"></a>
-<span class="sourceLineNo">1515</span> cluster.doAssignRegion(regionInfo, sn);<a name="line.1515"></a>
-<span class="sourceLineNo">1516</span> return sn;<a name="line.1516"></a>
-<span class="sourceLineNo">1517</span> }<a name="line.1517"></a>
-<span class="sourceLineNo">1518</span><a name="line.1518"></a>
-<span class="sourceLineNo">1519</span> /**<a name="line.1519"></a>
-<span class="sourceLineNo">1520</span> * Round robin a list of regions to a list of servers<a name="line.1520"></a>
-<span class="sourceLineNo">1521</span> */<a name="line.1521"></a>
-<span class="sourceLineNo">1522</span> private void roundRobinAssignment(Cluster cluster, List<RegionInfo> regions,<a name="line.1522"></a>
-<span class="sourceLineNo">1523</span> List<RegionInfo> unassignedRegions, List<ServerName> servers,<a name="line.1523"></a>
-<span class="sourceLineNo">1524</span> Map<ServerName, List<RegionInfo>> assignments) {<a name="line.1524"></a>
-<span class="sourceLineNo">1525</span><a name="line.1525"></a>
-<span class="sourceLineNo">1526</span> int numServers = servers.size();<a name="line.1526"></a>
-<span class="sourceLineNo">1527</span> int numRegions = regions.size();<a name="line.1527"></a>
-<span class="sourceLineNo">1528</span> int max = (int) Math.ceil((float) numRegions / numServers);<a name="line.1528"></a>
-<span class="sourceLineNo">1529</span> int serverIdx = 0;<a name="line.1529"></a>
-<span class="sourceLineNo">1530</span> if (numServers > 1) {<a name="line.1530"></a>
-<span class="sourceLineNo">1531</span> serverIdx = RANDOM.nextInt(numServers);<a name="line.1531"></a>
-<span class="sourceLineNo">1532</span> }<a name="line.1532"></a>
-<span class="sourceLineNo">1533</span> int regionIdx = 0;<a name="line.1533"></a>
-<span class="sourceLineNo">1534</span><a name="line.1534"></a>
-<span class="sourceLineNo">1535</span> for (int j = 0; j < numServers; j++) {<a name="line.1535"></a>
-<span class="sourceLineNo">1536</span> ServerName server = servers.get((j + serverIdx) % numServers);<a name="line.1536"></a>
-<span class="sourceLineNo">1537</span> List<RegionInfo> serverRegions = new ArrayList<>(max);<a name="line.1537"></a>
-<span class="sourceLineNo">1538</span> for (int i = regionIdx; i < numRegions; i += numServers) {<a name="line.1538"></a>
-<span class="sourceLineNo">1539</span> RegionInfo region = regions.get(i % numRegions);<a name="line.1539"></a>
-<span class="sourceLineNo">1540</span> if (cluster.wouldLowerAvailability(region, server)) {<a name="line.1540"></a>
-<span class="sourceLineNo">1541</span> unassignedRegions.add(region);<a name="line.1541"></a>
-<span class="sourceLineNo">1542</span> } else {<a name="line.1542"></a>
-<span class="sourceLineNo">1543</span> serverRegions.add(region);<a name="line.1543"></a>
-<span class="sourceLineNo">1544</span> cluster.doAssignRegion(region, server);<a name="line.1544"></a>
-<span class="sourceLineNo">1545</span> }<a name="line.1545"></a>
-<span class="sourceLineNo">1546</span> }<a name="line.1546"></a>
-<span class="sourceLineNo">1547</span> assignments.put(server, serverRegions);<a name="line.1547"></a>
-<span class="sourceLineNo">1548</span> regionIdx++;<a name="line.1548"></a>
+<span class="sourceLineNo">1495</span> public void initialize() throws HBaseIOException{<a name="line.1495"></a>
+<span class="sourceLineNo">1496</span> }<a name="line.1496"></a>
+<span class="sourceLineNo">1497</span><a name="line.1497"></a>
+<span class="sourceLineNo">1498</span> @Override<a name="line.1498"></a>
+<span class="sourceLineNo">1499</span> public void regionOnline(RegionInfo regionInfo, ServerName sn) {<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> @Override<a name="line.1502"></a>
+<span class="sourceLineNo">1503</span> public void regionOffline(RegionInfo regionInfo) {<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> @Override<a name="line.1506"></a>
+<span class="sourceLineNo">1507</span> public boolean isStopped() {<a name="line.1507"></a>
+<span class="sourceLineNo">1508</span> return stopped;<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> @Override<a name="line.1511"></a>
+<span class="sourceLineNo">1512</span> public void stop(String why) {<a name="line.1512"></a>
+<span class="sourceLineNo">1513</span> LOG.info("Load Balancer stop requested: "+why);<a name="line.1513"></a>
+<span class="sourceLineNo">1514</span> stopped = true;<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> * Used to assign a single region to a random server.<a name="line.1518"></a>
+<span class="sourceLineNo">1519</span> */<a name="line.1519"></a>
+<span class="sourceLineNo">1520</span> private ServerName randomAssignment(Cluster cluster, RegionInfo regionInfo,<a name="line.1520"></a>
+<span class="sourceLineNo">1521</span> List<ServerName> servers) {<a name="line.1521"></a>
+<span class="sourceLineNo">1522</span> int numServers = servers.size(); // servers is not null, numServers > 1<a name="line.1522"></a>
+<span class="sourceLineNo">1523</span> ServerName sn = null;<a name="line.1523"></a>
+<span class="sourceLineNo">1524</span> final int maxIterations = numServers * 4;<a name="line.1524"></a>
+<span class="sourceLineNo">1525</span> int iterations = 0;<a name="line.1525"></a>
+<span class="sourceLineNo">1526</span><a name="line.1526"></a>
+<span class="sourceLineNo">1527</span> do {<a name="line.1527"></a>
+<span class="sourceLineNo">1528</span> int i = RANDOM.nextInt(numServers);<a name="line.1528"></a>
+<span class="sourceLineNo">1529</span> sn = servers.get(i);<a name="line.1529"></a>
+<span class="sourceLineNo">1530</span> } while (cluster.wouldLowerAvailability(regionInfo, sn)<a name="line.1530"></a>
+<span class="sourceLineNo">1531</span> && iterations++ < maxIterations);<a name="line.1531"></a>
+<span class="sourceLineNo">1532</span> cluster.doAssignRegion(regionInfo, sn);<a name="line.1532"></a>
+<span class="sourceLineNo">1533</span> return sn;<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> /**<a name="line.1536"></a>
+<span class="sourceLineNo">1537</span> * Round robin a list of regions to a list of servers<a name="line.1537"></a>
+<span class="sourceLineNo">1538</span> */<a name="line.1538"></a>
+<span class="sourceLineNo">1539</span> private void roundRobinAssignment(Cluster cluster, List<RegionInfo> regions,<a name="line.1539"></a>
+<span class="sourceLineNo">1540</span> List<RegionInfo> unassignedRegions, List<ServerName> servers,<a name="line.1540"></a>
+<span class="sourceLineNo">1541</span> Map<ServerName, List<RegionInfo>> assignments) {<a name="line.1541"></a>
+<span class="sourceLineNo">1542</span><a name="line.1542"></a>
+<span class="sourceLineNo">1543</span> int numServers = servers.size();<a name="line.1543"></a>
+<span class="sourceLineNo">1544</span> int numRegions = regions.size();<a name="line.1544"></a>
+<span class="sourceLineNo">1545</span> int max = (int) Math.ceil((float) numRegions / numServers);<a name="line.1545"></a>
+<span class="sourceLineNo">1546</span> int serverIdx = 0;<a name="line.1546"></a>
+<span class="sourceLineNo">1547</span> if (numServers > 1) {<a name="line.1547"></a>
+<span class="sourceLineNo">1548</span> serverIdx = RANDOM.nextInt(numServers);<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">1550</span> int regionIdx = 0;<a name="line.1550"></a>
<span class="sourceLineNo">1551</span><a name="line.1551"></a>
-<span class="sourceLineNo">1552</span> protected Map<ServerName, List<RegionInfo>> getRegionAssignmentsByServer(<a name="line.1552"></a>
-<span class="sourceLineNo">1553</span> Collection<RegionInfo> regions) {<a name="line.1553"></a>
-<span class="sourceLineNo">1554</span> if (this.services != null && this.services.getAssignmentManager() != null) {<a name="line.1554"></a>
-<span class="sourceLineNo">1555</span> return this.services.getAssignmentManager().getSnapShotOfAssignment(regions);<a name="line.1555"></a>
-<span class="sourceLineNo">1556</span> } else {<a name="line.1556"></a>
-<span class="sourceLineNo">1557</span> return new HashMap<>();<a name="line.1557"></a>
-<span class="sourceLineNo">1558</span> }<a name="line.1558"></a>
-<span class="sourceLineNo">1559</span> }<a name="line.1559"></a>
-<span class="sourceLineNo">1560</span><a name="line.1560"></a>
-<span class="sourceLineNo">1561</span> @Override<a name="line.1561"></a>
-<span class="sourceLineNo">1562</span> public void onConfigurationChange(Configuration conf) {<a name="line.1562"></a>
-<span class="sourceLineNo">1563</span> }<a name="line.1563"></a>
-<span class="sourceLineNo">1564</span>}<a name="line.1564"></a>
+<span class="sourceLineNo">1552</span> for (int j = 0; j < numServers; j++) {<a name="line.1552"></a>
+<span class="sourceLineNo">1553</span> ServerName server = servers.get((j + serverIdx) % numServers);<a name="line.1553"></a>
+<span class="sourceLineNo">1554</span> List<RegionInfo> serverRegions = new ArrayList<>(max);<a name="line.1554"></a>
+<span class="sourceLineNo">1555</span> for (int i = regionIdx; i < numRegions; i += numServers) {<a name="line.1555"></a>
+<span class="sourceLineNo">1556</span> RegionInfo region = regions.get(i % numRegions);<a name="line.1556"></a>
+<span class="sourceLineNo">1557</span> if (cluster.wouldLowerAvailability(region, server)) {<a name="line.1557"></a>
+<span class="sourceLineNo">1558</span> unassignedRegions.add(region);<a name="line.1558"></a>
+<span class="sourceLineNo">1559</span> } else {<a name="line.1559"></a>
+<span class="sourceLineNo">1560</span> serverRegions.add(region);<a name="line.1560"></a>
+<span class="sourceLineNo">1561</span> cluster.doAssignRegion(region, server);<a name="line.1561"></a>
+<span class="sourceLineNo">1562</span> }<a name="line.1562"></a>
+<span class="sourceLineNo">1563</span> }<a name="line.1563"></a>
+<span class="sourceLineNo">1564</span> assignments.put(server, serverRegions);<a name="line.1564"></a>
+<span class="sourceLineNo">1565</span> regionIdx++;<a name="line.1565"></a>
+<span class="sourceLineNo">1566</span> }<a name="line.1566"></a>
+<span class="sourceLineNo">1567</span> }<a name="line.1567"></a>
+<span class="sourceLineNo">1568</span><a name="line.1568"></a>
+<span class="sourceLineNo">1569</span> protected Map<ServerName, List<RegionInfo>> getRegionAssignmentsByServer(<a name="line.1569"></a>
+<span class="sourceLineNo">1570</span> Collection<RegionInfo> regions) {<a name="line.1570"></a>
+<span class="sourceLineNo">1571</span> if (this.services != null && this.services.getAssignmentManager() != null) {<a name="line.1571"></a>
+<span class="sourceLineNo">1572</span> return this.services.getAssignmentManager().getSnapShotOfAssignment(regions);<a name="line.1572"></a>
+<span class="sourceLineNo">1573</span> } else {<a name="line.1573"></a>
+<span class="sourceLineNo">1574</span> return new HashMap<>();<a name="line.1574"></a>
+<span class="sourceLineNo">1575</span> }<a name="line.1575"></a>
+<span class="sourceLineNo">1576</span> }<a name="line.1576"></a>
+<span class="sourceLineNo">1577</span><a name="line.1577"></a>
+<span class="sourceLineNo">1578</span> @Override<a name="line.1578"></a>
+<span class="sourceLineNo">1579</span> public void onConfigurationChange(Configuration conf) {<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>
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/15a025c1/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 7e3039a..65b5edb 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
@@ -1421,155 +1421,172 @@
<span class="sourceLineNo">1413</span> // after the cluster restart.<a name="line.1413"></a>
<span class="sourceLineNo">1414</span> Set<String> oldHostsNoLongerPresent = Sets.newTreeSet();<a name="line.1414"></a>
<span class="sourceLineNo">1415</span><a name="line.1415"></a>
-<span class="sourceLineNo">1416</span> int numRandomAssignments = 0;<a name="line.1416"></a>
-<span class="sourceLineNo">1417</span> int numRetainedAssigments = 0;<a name="line.1417"></a>
+<span class="sourceLineNo">1416</span> // If the old servers aren't present, lets assign those regions later.<a name="line.1416"></a>
+<span class="sourceLineNo">1417</span> List<RegionInfo> randomAssignRegions = Lists.newArrayList();<a name="line.1417"></a>
<span class="sourceLineNo">1418</span><a name="line.1418"></a>
-<span class="sourceLineNo">1419</span> Cluster cluster = createCluster(servers, regions.keySet(), true);<a name="line.1419"></a>
-<span class="sourceLineNo">1420</span><a name="line.1420"></a>
-<span class="sourceLineNo">1421</span> for (Map.Entry<RegionInfo, ServerName> entry : regions.entrySet()) {<a name="line.1421"></a>
-<span class="sourceLineNo">1422</span> RegionInfo region = entry.getKey();<a name="line.1422"></a>
-<span class="sourceLineNo">1423</span> ServerName oldServerName = entry.getValue();<a name="line.1423"></a>
-<span class="sourceLineNo">1424</span> List<ServerName> localServers = new ArrayList<>();<a name="line.1424"></a>
-<span class="sourceLineNo">1425</span> if (oldServerName != null) {<a name="line.1425"></a>
-<span class="sourceLineNo">1426</span> localServers = serversByHostname.get(oldServerName.getHostname());<a name="line.1426"></a>
-<span class="sourceLineNo">1427</span> }<a name="line.1427"></a>
-<span class="sourceLineNo">1428</span> if (localServers.isEmpty()) {<a name="line.1428"></a>
-<span class="sourceLineNo">1429</span> // No servers on the new cluster match up with this hostname,<a name="line.1429"></a>
-<span class="sourceLineNo">1430</span> // assign randomly.<a name="line.1430"></a>
-<span class="sourceLineNo">1431</span> ServerName randomServer = randomAssignment(cluster, region, servers);<a name="line.1431"></a>
-<span class="sourceLineNo">1432</span> assignments.get(randomServer).add(region);<a name="line.1432"></a>
-<span class="sourceLineNo">1433</span> numRandomAssignments++;<a name="line.1433"></a>
-<span class="sourceLineNo">1434</span> if (oldServerName != null) oldHostsNoLongerPresent.add(oldServerName.getHostname());<a name="line.1434"></a>
-<span class="sourceLineNo">1435</span> } else if (localServers.size() == 1) {<a name="line.1435"></a>
-<span class="sourceLineNo">1436</span> // the usual case - one new server on same host<a name="line.1436"></a>
-<span class="sourceLineNo">1437</span> ServerName target = localServers.get(0);<a name="line.1437"></a>
-<span class="sourceLineNo">1438</span> assignments.get(target).add(region);<a name="line.1438"></a>
-<span class="sourceLineNo">1439</span> cluster.doAssignRegion(region, target);<a name="line.1439"></a>
-<span class="sourceLineNo">1440</span> numRetainedAssigments++;<a name="line.1440"></a>
-<span class="sourceLineNo">1441</span> } else {<a name="line.1441"></a>
-<span class="sourceLineNo">1442</span> // multiple new servers in the cluster on this same host<a name="line.1442"></a>
-<span class="sourceLineNo">1443</span> if (localServers.contains(oldServerName)) {<a name="line.1443"></a>
-<span class="sourceLineNo">1444</span> assignments.get(oldServerName).add(region);<a name="line.1444"></a>
-<span class="sourceLineNo">1445</span> cluster.doAssignRegion(region, oldServerName);<a name="line.1445"></a>
-<span class="sourceLineNo">1446</span> } else {<a name="line.1446"></a>
-<span class="sourceLineNo">1447</span> ServerName target = null;<a name="line.1447"></a>
-<span class="sourceLineNo">1448</span> for (ServerName tmp: localServers) {<a name="line.1448"></a>
-<span class="sourceLineNo">1449</span> if (tmp.getPort() == oldServerName.getPort()) {<a name="line.1449"></a>
-<span class="sourceLineNo">1450</span> target = tmp;<a name="line.1450"></a>
-<span class="sourceLineNo">1451</span> break;<a name="line.1451"></a>
-<span class="sourceLineNo">1452</span> }<a name="line.1452"></a>
-<span class="sourceLineNo">1453</span> }<a name="line.1453"></a>
-<span class="sourceLineNo">1454</span> if (target == null) {<a name="line.1454"></a>
-<span class="sourceLineNo">1455</span> target = randomAssignment(cluster, region, localServers);<a name="line.1455"></a>
+<span class="sourceLineNo">1419</span> int numRandomAssignments = 0;<a name="line.1419"></a>
+<span class="sourceLineNo">1420</span> int numRetainedAssigments = 0;<a name="line.1420"></a>
+<span class="sourceLineNo">1421</span><a name="line.1421"></a>
+<span class="sourceLineNo">1422</span> Cluster cluster = createCluster(servers, regions.keySet(), true);<a name="line.1422"></a>
+<span class="sourceLineNo">1423</span><a name="line.1423"></a>
+<span class="sourceLineNo">1424</span> for (Map.Entry<RegionInfo, ServerName> entry : regions.entrySet()) {<a name="line.1424"></a>
+<span class="sourceLineNo">1425</span> RegionInfo region = entry.getKey();<a name="line.1425"></a>
+<span class="sourceLineNo">1426</span> ServerName oldServerName = entry.getValue();<a name="line.1426"></a>
+<span class="sourceLineNo">1427</span> List<ServerName> localServers = new ArrayList<>();<a name="line.1427"></a>
+<span class="sourceLineNo">1428</span> if (oldServerName != null) {<a name="line.1428"></a>
+<span class="sourceLineNo">1429</span> localServers = serversByHostname.get(oldServerName.getHostname());<a name="line.1429"></a>
+<span class="sourceLineNo">1430</span> }<a name="line.1430"></a>
+<span class="sourceLineNo">1431</span> if (localServers.isEmpty()) {<a name="line.1431"></a>
+<span class="sourceLineNo">1432</span> // No servers on the new cluster match up with this hostname, assign randomly, later.<a name="line.1432"></a>
+<span class="sourceLineNo">1433</span> randomAssignRegions.add(region);<a name="line.1433"></a>
+<span class="sourceLineNo">1434</span> if (oldServerName != null) {<a name="line.1434"></a>
+<span class="sourceLineNo">1435</span> oldHostsNoLongerPresent.add(oldServerName.getHostname());<a name="line.1435"></a>
+<span class="sourceLineNo">1436</span> }<a name="line.1436"></a>
+<span class="sourceLineNo">1437</span> } else if (localServers.size() == 1) {<a name="line.1437"></a>
+<span class="sourceLineNo">1438</span> // the usual case - one new server on same host<a name="line.1438"></a>
+<span class="sourceLineNo">1439</span> ServerName target = localServers.get(0);<a name="line.1439"></a>
+<span class="sourceLineNo">1440</span> assignments.get(target).add(region);<a name="line.1440"></a>
+<span class="sourceLineNo">1441</span> numRetainedAssigments++;<a name="line.1441"></a>
+<span class="sourceLineNo">1442</span> } else {<a name="line.1442"></a>
+<span class="sourceLineNo">1443</span> // multiple new servers in the cluster on this same host<a name="line.1443"></a>
+<span class="sourceLineNo">1444</span> if (localServers.contains(oldServerName)) {<a name="line.1444"></a>
+<span class="sourceLineNo">1445</span> assignments.get(oldServerName).add(region);<a name="line.1445"></a>
+<span class="sourceLineNo">1446</span> numRetainedAssigments++;<a name="line.1446"></a>
+<span class="sourceLineNo">1447</span> } else {<a name="line.1447"></a>
+<span class="sourceLineNo">1448</span> ServerName target = null;<a name="line.1448"></a>
+<span class="sourceLineNo">1449</span> for (ServerName tmp : localServers) {<a name="line.1449"></a>
+<span class="sourceLineNo">1450</span> if (tmp.getPort() == oldServerName.getPort()) {<a name="line.1450"></a>
+<span class="sourceLineNo">1451</span> target = tmp;<a name="line.1451"></a>
+<span class="sourceLineNo">1452</span> assignments.get(tmp).add(region);<a name="line.1452"></a>
+<span class="sourceLineNo">1453</span> numRetainedAssigments++;<a name="line.1453"></a>
+<span class="sourceLineNo">1454</span> break;<a name="line.1454"></a>
+<span class="sourceLineNo">1455</span> }<a name="line.1455"></a>
<span class="sourceLineNo">1456</span> }<a name="line.1456"></a>
-<span class="sourceLineNo">1457</span> assignments.get(target).add(region);<a name="line.1457"></a>
-<span class="sourceLineNo">1458</span> }<a name="line.1458"></a>
-<span class="sourceLineNo">1459</span> numRetainedAssigments++;<a name="line.1459"></a>
-<span class="sourceLineNo">1460</span> }<a name="line.1460"></a>
-<span class="sourceLineNo">1461</span> }<a name="line.1461"></a>
-<span class="sourceLineNo">1462</span><a name="line.1462"></a>
-<span class="sourceLineNo">1463</span> String randomAssignMsg = "";<a name="line.1463"></a>
-<span class="sourceLineNo">1464</span> if (numRandomAssignments > 0) {<a name="line.1464"></a>
-<span class="sourceLineNo">1465</span> randomAssignMsg =<a name="line.1465"></a>
-<span class="sourceLineNo">1466</span> numRandomAssignments + " regions were assigned "<a name="line.1466"></a>
-<span class="sourceLineNo">1467</span> + "to random hosts, since the old hosts for these regions are no "<a name="line.1467"></a>
-<span class="sourceLineNo">1468</span> + "longer present in the cluster. These hosts were:\n "<a name="line.1468"></a>
-<span class="sourceLineNo">1469</span> + Joiner.on("\n ").join(oldHostsNoLongerPresent);<a name="line.1469"></a>
-<span class="sourceLineNo">1470</span> }<a name="line.1470"></a>
-<span class="sourceLineNo">1471</span><a name="line.1471"></a>
-<span class="sourceLineNo">1472</span> LOG.info("Reassigned " + regions.size() + " regions. " + numRetainedAssigments<a name="line.1472"></a>
-<span class="sourceLineNo">1473</span> + " retained the pre-restart assignment. " + randomAssignMsg);<a name="line.1473"></a>
-<span class="sourceLineNo">1474</span> return assignments;<a name="line.1474"></a>
-<span class="sourceLineNo">1475</span> }<a name="line.1475"></a>
-<span class="sourceLineNo">1476</span><a name="line.1476"></a>
-<span class="sourceLineNo">1477</span> @Override<a name="line.1477"></a>
-<span class="sourceLineNo">1478</span> public void initialize() throws HBaseIOException{<a name="line.1478"></a>
-<span class="sourceLineNo">1479</span> }<a name="line.1479"></a>
-<span class="sourceLineNo">1480</span><a name="line.1480"></a>
-<span class="sourceLineNo">1481</span> @Override<a name="line.1481"></a>
-<span class="sourceLineNo">1482</span> public void regionOnline(RegionInfo regionInfo, ServerName sn) {<a name="line.1482"></a>
-<span class="sourceLineNo">1483</span> }<a name="line.1483"></a>
-<span class="sourceLineNo">1484</span><a name="line.1484"></a>
-<span class="sourceLineNo">1485</span> @Override<a name="line.1485"></a>
-<span class="sourceLineNo">1486</span> public void regionOffline(RegionInfo regionInfo) {<a name="line.1486"></a>
-<span class="sourceLineNo">1487</span> }<a name="line.1487"></a>
+<span class="sourceLineNo">1457</span> if (target == null) {<a name="line.1457"></a>
+<span class="sourceLineNo">1458</span> randomAssignRegions.add(region);<a name="line.1458"></a>
+<span class="sourceLineNo">1459</span> }<a name="line.1459"></a>
+<span class="sourceLineNo">1460</span> }<a name="line.1460"></a>
+<span class="sourceLineNo">1461</span> }<a name="line.1461"></a>
+<span class="sourceLineNo">1462</span> }<a name="line.1462"></a>
+<span class="sourceLineNo">1463</span><a name="line.1463"></a>
+<span class="sourceLineNo">1464</span> // If servers from prior assignment aren't present, then lets do randomAssignment on regions.<a name="line.1464"></a>
+<span class="sourceLineNo">1465</span> if (randomAssignRegions.size() > 0) {<a name="line.1465"></a>
+<span class="sourceLineNo">1466</span> for (Map.Entry<ServerName, List<RegionInfo>> entry : assignments.entrySet()) {<a name="line.1466"></a>
+<span class="sourceLineNo">1467</span> ServerName sn = entry.getKey();<a name="line.1467"></a>
+<span class="sourceLineNo">1468</span> for (RegionInfo region : entry.getValue()) {<a name="line.1468"></a>
+<span class="sourceLineNo">1469</span> cluster.doAssignRegion(region, sn);<a name="line.1469"></a>
+<span class="sourceLineNo">1470</span> }<a name="line.1470"></a>
+<span class="sourceLineNo">1471</span> }<a name="line.1471"></a>
+<span class="sourceLineNo">1472</span> for (RegionInfo region : randomAssignRegions) {<a name="line.1472"></a>
+<span class="sourceLineNo">1473</span> ServerName target = randomAssignment(cluster, region, servers);<a name="line.1473"></a>
+<span class="sourceLineNo">1474</span> assignments.get(target).add(region);<a name="line.1474"></a>
+<span class="sourceLineNo">1475</span> cluster.doAssignRegion(region, target);<a name="line.1475"></a>
+<span class="sourceLineNo">1476</span> numRandomAssignments++;<a name="line.1476"></a>
+<span class="sourceLineNo">1477</span> }<a name="line.1477"></a>
+<span class="sourceLineNo">1478</span> }<a name="line.1478"></a>
+<span class="sourceLineNo">1479</span><a name="line.1479"></a>
+<span class="sourceLineNo">1480</span> String randomAssignMsg = "";<a name="line.1480"></a>
+<span class="sourceLineNo">1481</span> if (numRandomAssignments > 0) {<a name="line.1481"></a>
+<span class="sourceLineNo">1482</span> randomAssignMsg =<a name="line.1482"></a>
+<span class="sourceLineNo">1483</span> numRandomAssignments + " regions were assigned "<a name="line.1483"></a>
+<span class="sourceLineNo">1484</span> + "to random hosts, since the old hosts for these regions are no "<a name="line.1484"></a>
+<span class="sourceLineNo">1485</span> + "longer present in the cluster. These hosts were:\n "<a name="line.1485"></a>
+<span class="sourceLineNo">1486</span> + Joiner.on("\n ").join(oldHostsNoLongerPresent);<a name="line.1486"></a>
+<span class="sourceLineNo">1487</span> }<a name="line.1487"></a>
<span class="sourceLineNo">1488</span><a name="line.1488"></a>
-<span class="sourceLineNo">1489</span> @Override<a name="line.1489"></a>
-<span class="sourceLineNo">1490</span> public boolean isStopped() {<a name="line.1490"></a>
-<span class="sourceLineNo">1491</span> return stopped;<a name="line.1491"></a>
+<span class="sourceLineNo">1489</span> LOG.info("Reassigned " + regions.size() + " regions. " + numRetainedAssigments<a name="line.1489"></a>
+<span class="sourceLineNo">1490</span> + " retained the pre-restart assignment. " + randomAssignMsg);<a name="line.1490"></a>
+<span class="sourceLineNo">1491</span> return assignments;<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> @Override<a name="line.1494"></a>
-<span class="sourceLineNo">1495</span> public void stop(String why) {<a name="line.1495"></a>
-<span class="sourceLineNo">1496</span> LOG.info("Load Balancer stop requested: "+why);<a name="line.1496"></a>
-<span class="sourceLineNo">1497</span> stopped = true;<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> * Used to assign a single region to a random server.<a name="line.1501"></a>
-<span class="sourceLineNo">1502</span> */<a name="line.1502"></a>
-<span class="sourceLineNo">1503</span> private ServerName randomAssignment(Cluster cluster, RegionInfo regionInfo,<a name="line.1503"></a>
-<span class="sourceLineNo">1504</span> List<ServerName> servers) {<a name="line.1504"></a>
-<span class="sourceLineNo">1505</span> int numServers = servers.size(); // servers is not null, numServers > 1<a name="line.1505"></a>
-<span class="sourceLineNo">1506</span> ServerName sn = null;<a name="line.1506"></a>
-<span class="sourceLineNo">1507</span> final int maxIterations = numServers * 4;<a name="line.1507"></a>
-<span class="sourceLineNo">1508</span> int iterations = 0;<a name="line.1508"></a>
-<span class="sourceLineNo">1509</span><a name="line.1509"></a>
-<span class="sourceLineNo">1510</span> do {<a name="line.1510"></a>
-<span class="sourceLineNo">1511</span> int i = RANDOM.nextInt(numServers);<a name="line.1511"></a>
-<span class="sourceLineNo">1512</span> sn = servers.get(i);<a name="line.1512"></a>
-<span class="sourceLineNo">1513</span> } while (cluster.wouldLowerAvailability(regionInfo, sn)<a name="line.1513"></a>
-<span class="sourceLineNo">1514</span> && iterations++ < maxIterations);<a name="line.1514"></a>
-<span class="sourceLineNo">1515</span> cluster.doAssignRegion(regionInfo, sn);<a name="line.1515"></a>
-<span class="sourceLineNo">1516</span> return sn;<a name="line.1516"></a>
-<span class="sourceLineNo">1517</span> }<a name="line.1517"></a>
-<span class="sourceLineNo">1518</span><a name="line.1518"></a>
-<span class="sourceLineNo">1519</span> /**<a name="line.1519"></a>
-<span class="sourceLineNo">1520</span> * Round robin a list of regions to a list of servers<a name="line.1520"></a>
-<span class="sourceLineNo">1521</span> */<a name="line.1521"></a>
-<span class="sourceLineNo">1522</span> private void roundRobinAssignment(Cluster cluster, List<RegionInfo> regions,<a name="line.1522"></a>
-<span class="sourceLineNo">1523</span> List<RegionInfo> unassignedRegions, List<ServerName> servers,<a name="line.1523"></a>
-<span class="sourceLineNo">1524</span> Map<ServerName, List<RegionInfo>> assignments) {<a name="line.1524"></a>
-<span class="sourceLineNo">1525</span><a name="line.1525"></a>
-<span class="sourceLineNo">1526</span> int numServers = servers.size();<a name="line.1526"></a>
-<span class="sourceLineNo">1527</span> int numRegions = regions.size();<a name="line.1527"></a>
-<span class="sourceLineNo">1528</span> int max = (int) Math.ceil((float) numRegions / numServers);<a name="line.1528"></a>
-<span class="sourceLineNo">1529</span> int serverIdx = 0;<a name="line.1529"></a>
-<span class="sourceLineNo">1530</span> if (numServers > 1) {<a name="line.1530"></a>
-<span class="sourceLineNo">1531</span> serverIdx = RANDOM.nextInt(numServers);<a name="line.1531"></a>
-<span class="sourceLineNo">1532</span> }<a name="line.1532"></a>
-<span class="sourceLineNo">1533</span> int regionIdx = 0;<a name="line.1533"></a>
-<span class="sourceLineNo">1534</span><a name="line.1534"></a>
-<span class="sourceLineNo">1535</span> for (int j = 0; j < numServers; j++) {<a name="line.1535"></a>
-<span class="sourceLineNo">1536</span> ServerName server = servers.get((j + serverIdx) % numServers);<a name="line.1536"></a>
-<span class="sourceLineNo">1537</span> List<RegionInfo> serverRegions = new ArrayList<>(max);<a name="line.1537"></a>
-<span class="sourceLineNo">1538</span> for (int i = regionIdx; i < numRegions; i += numServers) {<a name="line.1538"></a>
-<span class="sourceLineNo">1539</span> RegionInfo region = regions.get(i % numRegions);<a name="line.1539"></a>
-<span class="sourceLineNo">1540</span> if (cluster.wouldLowerAvailability(region, server)) {<a name="line.1540"></a>
-<span class="sourceLineNo">1541</span> unassignedRegions.add(region);<a name="line.1541"></a>
-<span class="sourceLineNo">1542</span> } else {<a name="line.1542"></a>
-<span class="sourceLineNo">1543</span> serverRegions.add(region);<a name="line.1543"></a>
-<span class="sourceLineNo">1544</span> cluster.doAssignRegion(region, server);<a name="line.1544"></a>
-<span class="sourceLineNo">1545</span> }<a name="line.1545"></a>
-<span class="sourceLineNo">1546</span> }<a name="line.1546"></a>
-<span class="sourceLineNo">1547</span> assignments.put(server, serverRegions);<a name="line.1547"></a>
-<span class="sourceLineNo">1548</span> regionIdx++;<a name="line.1548"></a>
+<span class="sourceLineNo">1495</span> public void initialize() throws HBaseIOException{<a name="line.1495"></a>
+<span class="sourceLineNo">1496</span> }<a name="line.1496"></a>
+<span class="sourceLineNo">1497</span><a name="line.1497"></a>
+<span class="sourceLineNo">1498</span> @Override<a name="line.1498"></a>
+<span class="sourceLineNo">1499</span> public void regionOnline(RegionInfo regionInfo, ServerName sn) {<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> @Override<a name="line.1502"></a>
+<span class="sourceLineNo">1503</span> public void regionOffline(RegionInfo regionInfo) {<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> @Override<a name="line.1506"></a>
+<span class="sourceLineNo">1507</span> public boolean isStopped() {<a name="line.1507"></a>
+<span class="sourceLineNo">1508</span> return stopped;<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> @Override<a name="line.1511"></a>
+<span class="sourceLineNo">1512</span> public void stop(String why) {<a name="line.1512"></a>
+<span class="sourceLineNo">1513</span> LOG.info("Load Balancer stop requested: "+why);<a name="line.1513"></a>
+<span class="sourceLineNo">1514</span> stopped = true;<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> * Used to assign a single region to a random server.<a name="line.1518"></a>
+<span class="sourceLineNo">1519</span> */<a name="line.1519"></a>
+<span class="sourceLineNo">1520</span> private ServerName randomAssignment(Cluster cluster, RegionInfo regionInfo,<a name="line.1520"></a>
+<span class="sourceLineNo">1521</span> List<ServerName> servers) {<a name="line.1521"></a>
+<span class="sourceLineNo">1522</span> int numServers = servers.size(); // servers is not null, numServers > 1<a name="line.1522"></a>
+<span class="sourceLineNo">1523</span> ServerName sn = null;<a name="line.1523"></a>
+<span class="sourceLineNo">1524</span> final int maxIterations = numServers * 4;<a name="line.1524"></a>
+<span class="sourceLineNo">1525</span> int iterations = 0;<a name="line.1525"></a>
+<span class="sourceLineNo">1526</span><a name="line.1526"></a>
+<span class="sourceLineNo">1527</span> do {<a name="line.1527"></a>
+<span class="sourceLineNo">1528</span> int i = RANDOM.nextInt(numServers);<a name="line.1528"></a>
+<span class="sourceLineNo">1529</span> sn = servers.get(i);<a name="line.1529"></a>
+<span class="sourceLineNo">1530</span> } while (cluster.wouldLowerAvailability(regionInfo, sn)<a name="line.1530"></a>
+<span class="sourceLineNo">1531</span> && iterations++ < maxIterations);<a name="line.1531"></a>
+<span class="sourceLineNo">1532</span> cluster.doAssignRegion(regionInfo, sn);<a name="line.1532"></a>
+<span class="sourceLineNo">1533</span> return sn;<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> /**<a name="line.1536"></a>
+<span class="sourceLineNo">1537</span> * Round robin a list of regions to a list of servers<a name="line.1537"></a>
+<span class="sourceLineNo">1538</span> */<a name="line.1538"></a>
+<span class="sourceLineNo">1539</span> private void roundRobinAssignment(Cluster cluster, List<RegionInfo> regions,<a name="line.1539"></a>
+<span class="sourceLineNo">1540</span> List<RegionInfo> unassignedRegions, List<ServerName> servers,<a name="line.1540"></a>
+<span class="sourceLineNo">1541</span> Map<ServerName, List<RegionInfo>> assignments) {<a name="line.1541"></a>
+<span class="sourceLineNo">1542</span><a name="line.1542"></a>
+<span class="sourceLineNo">1543</span> int numServers = servers.size();<a name="line.1543"></a>
+<span class="sourceLineNo">1544</span> int numRegions = regions.size();<a name="line.1544"></a>
+<span class="sourceLineNo">1545</span> int max = (int) Math.ceil((float) numRegions / numServers);<a name="line.1545"></a>
+<span class="sourceLineNo">1546</span> int serverIdx = 0;<a name="line.1546"></a>
+<span class="sourceLineNo">1547</span> if (numServers > 1) {<a name="line.1547"></a>
+<span class="sourceLineNo">1548</span> serverIdx = RANDOM.nextInt(numServers);<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">1550</span> int regionIdx = 0;<a name="line.1550"></a>
<span class="sourceLineNo">1551</span><a name="line.1551"></a>
-<span class="sourceLineNo">1552</span> protected Map<ServerName, List<RegionInfo>> getRegionAssignmentsByServer(<a name="line.1552"></a>
-<span class="sourceLineNo">1553</span> Collection<RegionInfo> regions) {<a name="line.1553"></a>
-<span class="sourceLineNo">1554</span> if (this.services != null && this.services.getAssignmentManager() != null) {<a name="line.1554"></a>
-<span class="sourceLineNo">1555</span> return this.services.getAssignmentManager().getSnapShotOfAssignment(regions);<a name="line.1555"></a>
-<span class="sourceLineNo">1556</span> } else {<a name="line.1556"></a>
-<span class="sourceLineNo">1557</span> return new HashMap<>();<a name="line.1557"></a>
-<span class="sourceLineNo">1558</span> }<a name="line.1558"></a>
-<span class="sourceLineNo">1559</span> }<a name="line.1559"></a>
-<span class="sourceLineNo">1560</span><a name="line.1560"></a>
-<span class="sourceLineNo">1561</span> @Override<a name="line.1561"></a>
-<span class="sourceLineNo">1562</span> public void onConfigurationChange(Configuration conf) {<a name="line.1562"></a>
-<span class="sourceLineNo">1563</span> }<a name="line.1563"></a>
-<span class="sourceLineNo">1564</span>}<a name="line.1564"></a>
+<span class="sourceLineNo">1552</span> for (int j = 0; j < numServers; j++) {<a name="line.1552"></a>
+<span class="sourceLineNo">1553</span> ServerName server = servers.get((j + serverIdx) % numServers);<a name="line.1553"></a>
+<span class="sourceLineNo">1554</span> List<RegionInfo> serverRegions = new ArrayList<>(max);<a name="line.1554"></a>
+<span class="sourceLineNo">1555</span> for (int i = regionIdx; i < numRegions; i += numServers) {<a name="line.1555"></a>
+<span class="sourceLineNo">1556</span> RegionInfo region = regions.get(i % numRegions);<a name="line.1556"></a>
+<span class="sourceLineNo">1557</span> if (cluster.wouldLowerAvailability(region, server)) {<a name="line.1557"></a>
+<span class="sourceLineNo">1558</span> unassignedRegions.add(region);<a name="line.1558"></a>
+<span class="sourceLineNo">1559</span> } else {<a name="line.1559"></a>
+<span class="sourceLineNo">1560</span> serverRegions.add(region);<a name="line.1560"></a>
+<span class="sourceLineNo">1561</span> cluster.doAssignRegion(region, server);<a name="line.1561"></a>
+<span class="sourceLineNo">1562</span> }<a name="line.1562"></a>
+<span class="sourceLineNo">1563</span> }<a name="line.1563"></a>
+<span class="sourceLineNo">1564</span> assignments.put(server, serverRegions);<a name="line.1564"></a>
+<span class="sourceLineNo">1565</span> regionIdx++;<a name="line.1565"></a>
+<span class="sourceLineNo">1566</span> }<a name="line.1566"></a>
+<span class="sourceLineNo">1567</span> }<a name="line.1567"></a>
+<span class="sourceLineNo">1568</span><a name="line.1568"></a>
+<span class="sourceLineNo">1569</span> protected Map<ServerName, List<RegionInfo>> getRegionAssignmentsByServer(<a name="line.1569"></a>
+<span class="sourceLineNo">1570</span> Collection<RegionInfo> regions) {<a name="line.1570"></a>
+<span class="sourceLineNo">1571</span> if (this.services != null && this.services.getAssignmentManager() != null) {<a name="line.1571"></a>
+<span class="sourceLineNo">1572</span> return this.services.getAssignmentManager().getSnapShotOfAssignment(regions);<a name="line.1572"></a>
+<span class="sourceLineNo">1573</span> } else {<a name="line.1573"></a>
+<span class="sourceLineNo">1574</span> return new HashMap<>();<a name="line.1574"></a>
+<span class="sourceLineNo">1575</span> }<a name="line.1575"></a>
+<span class="sourceLineNo">1576</span> }<a name="line.1576"></a>
+<span class="sourceLineNo">1577</span><a name="line.1577"></a>
+<span class="sourceLineNo">1578</span> @Override<a name="line.1578"></a>
+<span class="sourceLineNo">1579</span> public void onConfigurationChange(Configuration conf) {<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>