Repository: hadoop Updated Branches: refs/heads/trunk 4f4250fbc -> cfcd52732
HDFS-11411. Avoid OutOfMemoryError in TestMaintenanceState test runs. (Manoj Govindassamy via mingma) Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/cfcd5273 Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/cfcd5273 Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/cfcd5273 Branch: refs/heads/trunk Commit: cfcd527323352cf2a851c5c41f5d243d375d88d0 Parents: 4f4250f Author: Ming Ma <[email protected]> Authored: Wed Feb 22 09:41:07 2017 -0800 Committer: Ming Ma <[email protected]> Committed: Wed Feb 22 09:41:07 2017 -0800 ---------------------------------------------------------------------- .../test/java/org/apache/hadoop/hdfs/TestMaintenanceState.java | 6 ++++++ 1 file changed, 6 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hadoop/blob/cfcd5273/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/TestMaintenanceState.java ---------------------------------------------------------------------- diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/TestMaintenanceState.java b/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/TestMaintenanceState.java index bbf947f..f3e2a0b 100644 --- a/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/TestMaintenanceState.java +++ b/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/TestMaintenanceState.java @@ -333,6 +333,7 @@ public class TestMaintenanceState extends AdminStatesBaseTest { private void testExpectedReplication(int replicationFactor, int expectedReplicasInRead) throws IOException { + setup(); startCluster(1, 5); final Path file = new Path("/testExpectedReplication.dat"); @@ -352,6 +353,7 @@ public class TestMaintenanceState extends AdminStatesBaseTest { nodeOutofService)); cleanupFile(fileSys, file); + teardown(); } /** @@ -492,6 +494,7 @@ public class TestMaintenanceState extends AdminStatesBaseTest { private void testDecommissionDifferentNodeAfterMaintenance(int repl) throws Exception { + setup(); startCluster(1, 5); final Path file = @@ -519,6 +522,7 @@ public class TestMaintenanceState extends AdminStatesBaseTest { assertNull(checkWithRetry(ns, fileSys, file, repl + 1, null)); cleanupFile(fileSys, file); + teardown(); } /** @@ -583,6 +587,7 @@ public class TestMaintenanceState extends AdminStatesBaseTest { */ private void testChangeReplicationFactor(int oldFactor, int newFactor, int expectedLiveReplicas) throws IOException { + setup(); LOG.info("Starting testChangeReplicationFactor {} {} {}", oldFactor, newFactor, expectedLiveReplicas); startCluster(1, 5); @@ -615,6 +620,7 @@ public class TestMaintenanceState extends AdminStatesBaseTest { assertNull(checkWithRetry(ns, fileSys, file, newFactor, null)); cleanupFile(fileSys, file); + teardown(); } --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
