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

HBASE-14327 TestIOFencing#testFencingAroundCompactionAfterWALSync is flaky (Heng Chen)

This commit is contained in:
stack 2015-09-04 10:27:49 -07:00
parent 513b37603d
commit 1ac42c9634
1 changed files with 7 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
hbase-server/src/test/java/org/apache/hadoop/hbase/TestIOFencing.java
View File

@ -321,6 +321,12 @@ public class TestIOFencing {
newRegion = (CompactionBlockerRegion)newServer.getOnlineRegion(REGION_NAME); newRegion = (CompactionBlockerRegion)newServer.getOnlineRegion(REGION_NAME);
// After compaction of old region finishes on the server that was going down, make sure that
// all the files we expect are still working when region is up in new location.
FileSystem fs = newRegion.getFilesystem();
for (String f: newRegion.getStoreFileList(new byte [][] {FAMILY})) {
assertTrue("After compaction, does not exist: " + f, fs.exists(new Path(f)));
}
LOG.info("Allowing compaction to proceed"); LOG.info("Allowing compaction to proceed");
compactingRegion.allowCompactions(); compactingRegion.allowCompactions();
while (compactingRegion.compactCount == 0) { while (compactingRegion.compactCount == 0) {
@ -329,12 +335,7 @@ public class TestIOFencing {
// The server we killed stays up until the compaction that was started before it was killed completes. In logs // The server we killed stays up until the compaction that was started before it was killed completes. In logs
// you should see the old regionserver now going down. // you should see the old regionserver now going down.
LOG.info("Compaction finished"); LOG.info("Compaction finished");
// After compaction of old region finishes on the server that was going down, make sure that
// all the files we expect are still working when region is up in new location.
FileSystem fs = newRegion.getFilesystem();
for (String f: newRegion.getStoreFileList(new byte [][] {FAMILY})) {
assertTrue("After compaction, does not exist: " + f, fs.exists(new Path(f)));
}
// If we survive the split keep going... // If we survive the split keep going...
// Now we make sure that the region isn't totally confused. Load up more rows. // Now we make sure that the region isn't totally confused. Load up more rows.
TEST_UTIL.loadNumericRows(table, FAMILY, FIRST_BATCH_COUNT, FIRST_BATCH_COUNT + SECOND_BATCH_COUNT); TEST_UTIL.loadNumericRows(table, FAMILY, FIRST_BATCH_COUNT, FIRST_BATCH_COUNT + SECOND_BATCH_COUNT);