Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-18923 TestTableResource flaky on branch-1 

Signed-off-by: Andrew Purtell <apurtell@apache.org>
This commit is contained in:
Pankaj Kumar 2017-10-05 11:44:29 +05:30 committed by Andrew Purtell
parent aa50971947
commit c48155a4d1
1 changed files with 14 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
hbase-rest/src/test/java/org/apache/hadoop/hbase/rest/TestTableResource.java
View File

@ -42,6 +42,7 @@ import org.apache.hadoop.hbase.HTableDescriptor;
import org.apache.hadoop.hbase.KeyValue; import org.apache.hadoop.hbase.KeyValue;
import org.apache.hadoop.hbase.ServerName; import org.apache.hadoop.hbase.ServerName;
import org.apache.hadoop.hbase.TableName; import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.Waiter;
import org.apache.hadoop.hbase.client.Admin; import org.apache.hadoop.hbase.client.Admin;
import org.apache.hadoop.hbase.client.Connection; import org.apache.hadoop.hbase.client.Connection;
import org.apache.hadoop.hbase.client.Durability; import org.apache.hadoop.hbase.client.Durability;
@ -57,7 +58,7 @@ import org.apache.hadoop.hbase.rest.model.TableModel;
import org.apache.hadoop.hbase.rest.model.TableRegionModel; import org.apache.hadoop.hbase.rest.model.TableRegionModel;
import org.apache.hadoop.hbase.testclassification.MediumTests; import org.apache.hadoop.hbase.testclassification.MediumTests;
import org.apache.hadoop.hbase.util.Bytes; import org.apache.hadoop.hbase.util.Bytes;
import org.apache.hadoop.util.StringUtils; import org.apache.hadoop.hbase.util.EnvironmentEdgeManager;
import org.junit.AfterClass; import org.junit.AfterClass;
import org.junit.BeforeClass; import org.junit.BeforeClass;
import org.junit.Test; import org.junit.Test;
@ -119,26 +120,26 @@ public class TestTableResource {
table.close(); table.close();
// get the initial layout (should just be one region) // get the initial layout (should just be one region)
RegionLocator regionLocator = connection.getRegionLocator(TABLE); final RegionLocator regionLocator = connection.getRegionLocator(TABLE);
List<HRegionLocation> m = regionLocator.getAllRegionLocations(); List<HRegionLocation> m = regionLocator.getAllRegionLocations();
assertEquals(m.size(), 1); assertEquals(m.size(), 1);
// tell the master to split the table // tell the master to split the table
admin.split(TABLE); admin.split(TABLE);
// give some time for the split to happen
long timeout = System.currentTimeMillis() + (15 * 1000); // give some time for the split to happen
while (System.currentTimeMillis() < timeout && m.size()!=2){ long timeout = EnvironmentEdgeManager.currentTime() + (15 * 1000);
try { TEST_UTIL.waitFor(timeout, 250, new Waiter.Predicate<IOException>() {
Thread.sleep(250); @Override
} catch (InterruptedException e) { public boolean evaluate() throws IOException {
LOG.warn(StringUtils.stringifyException(e)); List<HRegionLocation> regionLocations = regionLocator.getAllRegionLocations();
return regionLocations.size() == 2 && regionLocations.get(0).getServerName() != null
&& regionLocations.get(1).getServerName() != null;
} }
// check again });
m = regionLocator.getAllRegionLocations(); m = regionLocator.getAllRegionLocations();
}
// should have two regions now // should have two regions now
assertEquals(m.size(), 2); assertEquals(2, m.size());
regionMap = m; regionMap = m;
LOG.info("regions: " + regionMap); LOG.info("regions: " + regionMap);
regionLocator.close(); regionLocator.close();