hbase-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From st...@apache.org
Subject [1/2] hbase git commit: HBASE-14327 TestIOFencing#testFencingAroundCompactionAfterWALSync is flaky (Heng Chen)
Date Fri, 02 Oct 2015 20:31:51 GMT
Repository: hbase
Updated Branches:
  refs/heads/branch-1.0 dfc61c6ec -> bda54c5c6


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


Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/0cc5a5d8
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/0cc5a5d8
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/0cc5a5d8

Branch: refs/heads/branch-1.0
Commit: 0cc5a5d8cffd901c7e0883f24da4e6e808aefb39
Parents: dfc61c6
Author: stack <stack@apache.org>
Authored: Fri Sep 4 10:27:49 2015 -0700
Committer: stack <stack@apache.org>
Committed: Fri Oct 2 13:31:26 2015 -0700

----------------------------------------------------------------------
 .../java/org/apache/hadoop/hbase/TestIOFencing.java    | 13 +++++++------
 1 file changed, 7 insertions(+), 6 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hbase/blob/0cc5a5d8/hbase-server/src/test/java/org/apache/hadoop/hbase/TestIOFencing.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/TestIOFencing.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/TestIOFencing.java
index 48feb03..6414be7 100644
--- a/hbase-server/src/test/java/org/apache/hadoop/hbase/TestIOFencing.java
+++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/TestIOFencing.java
@@ -315,6 +315,12 @@ public class TestIOFencing {
 
       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");
       compactingRegion.allowCompactions();
       while (compactingRegion.compactCount == 0) {
@@ -323,12 +329,7 @@ public class TestIOFencing {
       // 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.
       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...
       // 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);


Mime
View raw message