diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/util/TestFSUtils.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/util/TestFSUtils.java index c8b2285..e2c1488 100644 --- a/hbase-server/src/test/java/org/apache/hadoop/hbase/util/TestFSUtils.java +++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/util/TestFSUtils.java @@ -330,16 +330,19 @@ public class TestFSUtils { ManualEnvironmentEdge mockEnv = new ManualEnvironmentEdge(); mockEnv.setValue(expect); EnvironmentEdgeManager.injectEdge(mockEnv); + try { + String dstFile = UUID.randomUUID().toString(); + Path dst = new Path(testDir , dstFile); - String dstFile = UUID.randomUUID().toString(); - Path dst = new Path(testDir , dstFile); - - assertTrue(FSUtils.renameAndSetModifyTime(fs, p, dst)); - assertFalse("The moved file should not be present", FSUtils.isExists(fs, p)); - assertTrue("The dst file should be present", FSUtils.isExists(fs, dst)); + assertTrue(FSUtils.renameAndSetModifyTime(fs, p, dst)); + assertFalse("The moved file should not be present", FSUtils.isExists(fs, p)); + assertTrue("The dst file should be present", FSUtils.isExists(fs, dst)); - assertEquals(expect, fs.getFileStatus(dst).getModificationTime()); - cluster.shutdown(); + assertEquals(expect, fs.getFileStatus(dst).getModificationTime()); + cluster.shutdown(); + } finally { + EnvironmentEdgeManager.reset(); + } } /** diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/util/TestHBaseFsck.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/util/TestHBaseFsck.java index ba7ba9c..ac2d906 100644 --- a/hbase-server/src/test/java/org/apache/hadoop/hbase/util/TestHBaseFsck.java +++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/util/TestHBaseFsck.java @@ -111,6 +111,7 @@ import org.apache.hadoop.hbase.zookeeper.MetaTableLocator; import org.apache.zookeeper.KeeperException; import org.junit.AfterClass; import org.junit.Assert; +import org.junit.Before; import org.junit.BeforeClass; import org.junit.Ignore; import org.junit.Test; @@ -182,6 +183,11 @@ public class TestHBaseFsck { TEST_UTIL.shutdownMiniCluster(); } + @Before + public void setUp() { + EnvironmentEdgeManager.reset(); + } + @Test (timeout=180000) public void testHBaseFsck() throws Exception { assertNoErrors(doFsck(conf, false));