diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestTags.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestTags.java index 3de6ed3..70a5855 100644 --- a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestTags.java +++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestTags.java @@ -123,13 +123,7 @@ public class TestTags { put.setAttribute("visibility", Bytes.toBytes("myTag")); table.put(put); admin.flush(tableName.getName()); - List regions = TEST_UTIL.getHBaseCluster().getRegions(tableName.getName()); - for (HRegion region : regions) { - Store store = region.getStore(fam); - while (!(store.getStorefilesCount() > 0)) { - Thread.sleep(10); - } - } + Thread.sleep(1000); Put put1 = new Put(row1); byte[] value1 = Bytes.toBytes("1000dfsdf"); @@ -137,28 +131,16 @@ public class TestTags { // put1.setAttribute("visibility", Bytes.toBytes("myTag3")); table.put(put1); admin.flush(tableName.getName()); - regions = TEST_UTIL.getHBaseCluster().getRegions(tableName.getName()); - for (HRegion region : regions) { - Store store = region.getStore(fam); - while (!(store.getStorefilesCount() > 1)) { - Thread.sleep(10); - } - } + Thread.sleep(1000); Put put2 = new Put(row2); byte[] value2 = Bytes.toBytes("1000dfsdf"); put2.add(fam, qual, HConstants.LATEST_TIMESTAMP, value2); put2.setAttribute("visibility", Bytes.toBytes("myTag3")); table.put(put2); - admin.flush(tableName.getName()); - regions = TEST_UTIL.getHBaseCluster().getRegions(tableName.getName()); - for (HRegion region : regions) { - Store store = region.getStore(fam); - while (!(store.getStorefilesCount() > 2)) { - Thread.sleep(10); - } - } + Thread.sleep(1000); + result(fam, row, qual, row2, table, value, value2, row1, value1); admin.compact(tableName.getName()); while (admin.getCompactionState(tableName.getName()) != CompactionState.NONE) { @@ -201,40 +183,22 @@ public class TestTags { put.add(fam, qual, HConstants.LATEST_TIMESTAMP, value); table.put(put); admin.flush(tableName.getName()); - List regions = TEST_UTIL.getHBaseCluster().getRegions(tableName.getName()); - for (HRegion region : regions) { - Store store = region.getStore(fam); - while (!(store.getStorefilesCount() > 0)) { - Thread.sleep(10); - } - } + Thread.sleep(1000); Put put1 = new Put(row1); byte[] value1 = Bytes.toBytes("1000dfsdf"); put1.add(fam, qual, HConstants.LATEST_TIMESTAMP, value1); table.put(put1); admin.flush(tableName.getName()); - regions = TEST_UTIL.getHBaseCluster().getRegions(tableName.getName()); - for (HRegion region : regions) { - Store store = region.getStore(fam); - while (!(store.getStorefilesCount() > 1)) { - Thread.sleep(10); - } - } + Thread.sleep(1000); Put put2 = new Put(row2); byte[] value2 = Bytes.toBytes("1000dfsdf"); put2.add(fam, qual, HConstants.LATEST_TIMESTAMP, value2); table.put(put2); - admin.flush(tableName.getName()); - regions = TEST_UTIL.getHBaseCluster().getRegions(tableName.getName()); - for (HRegion region : regions) { - Store store = region.getStore(fam); - while (!(store.getStorefilesCount() > 2)) { - Thread.sleep(10); - } - } + Thread.sleep(1000); + Scan s = new Scan(row); ResultScanner scanner = table.getScanner(s); try { @@ -312,26 +276,15 @@ public class TestTags { put1.add(fam, qual, HConstants.LATEST_TIMESTAMP, value1); table.put(put1); admin.flush(tableName.getName()); - List regions = TEST_UTIL.getHBaseCluster().getRegions(tableName.getName()); - for (HRegion region : regions) { - Store store = region.getStore(fam); - while (!(store.getStorefilesCount() > 0)) { - Thread.sleep(10); - } - } + Thread.sleep(1000); put1 = new Put(row2); value1 = Bytes.toBytes("1000dfsdf"); put1.add(fam, qual, HConstants.LATEST_TIMESTAMP, value1); table.put(put1); admin.flush(tableName.getName()); - regions = TEST_UTIL.getHBaseCluster().getRegions(tableName.getName()); - for (HRegion region : regions) { - Store store = region.getStore(fam); - while (!(store.getStorefilesCount() > 1)) { - Thread.sleep(10); - } - } + Thread.sleep(1000); + Put put2 = new Put(rowd); byte[] value2 = Bytes.toBytes("1000dfsdf"); put2.add(fam, qual, HConstants.LATEST_TIMESTAMP, value2); @@ -342,13 +295,8 @@ public class TestTags { put.setAttribute("visibility", Bytes.toBytes("ram")); table.put(put2); admin.flush(tableName.getName()); - regions = TEST_UTIL.getHBaseCluster().getRegions(tableName.getName()); - for (HRegion region : regions) { - Store store = region.getStore(fam); - while (!(store.getStorefilesCount() > 2)) { - Thread.sleep(10); - } - } + Thread.sleep(1000); + TestCoprocessorForTags.checkTagPresence = true; Scan s = new Scan(row); s.setCaching(1);