|
@@ -34,6 +34,7 @@ import org.apache.hadoop.mapreduce.MRConfig;
|
|
|
import org.apache.hadoop.mapreduce.MRJobConfig;
|
|
|
import org.apache.hadoop.mapreduce.checkpoint.TaskCheckpointID;
|
|
|
import org.apache.hadoop.util.ExitUtil;
|
|
|
+import org.junit.After;
|
|
|
import org.junit.Assert;
|
|
|
import org.junit.Test;
|
|
|
|
|
@@ -179,6 +180,11 @@ public class TestTaskProgressReporter {
|
|
|
}
|
|
|
}
|
|
|
|
|
|
+ @After
|
|
|
+ public void cleanup() {
|
|
|
+ FileSystem.clearStatistics();
|
|
|
+ }
|
|
|
+
|
|
|
@Test(timeout=60000)
|
|
|
public void testScratchDirSize() throws Exception {
|
|
|
String tmpPath = TEST_DIR + "/testBytesWrittenLimit-tmpFile-"
|