Repository: hadoop Updated Branches: refs/heads/branch-3.1 3b646a983 -> f2bcb8163
MAPREDUCE-7108. TestFileOutputCommitter fails on Windows. (Zuoming Zhang via gera) (cherry picked from commit 04b74eddc67888142879ed114d21348e8a4aad78) Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/f2bcb816 Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/f2bcb816 Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/f2bcb816 Branch: refs/heads/branch-3.1 Commit: f2bcb8163a1b65744fe94cf7c8e478cdc8cc569d Parents: 3b646a9 Author: Gera Shegalov <g...@apache.org> Authored: Tue Jun 12 11:21:51 2018 -0700 Committer: Gera Shegalov <g...@apache.org> Committed: Tue Jun 12 13:02:41 2018 -0700 ---------------------------------------------------------------------- .../lib/output/TestFileOutputCommitter.java | 16 ++++++++-------- 1 file changed, 8 insertions(+), 8 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hadoop/blob/f2bcb816/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/test/java/org/apache/hadoop/mapreduce/lib/output/TestFileOutputCommitter.java ---------------------------------------------------------------------- diff --git a/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/test/java/org/apache/hadoop/mapreduce/lib/output/TestFileOutputCommitter.java b/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/test/java/org/apache/hadoop/mapreduce/lib/output/TestFileOutputCommitter.java index cd9d44b..fc43dce 100644 --- a/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/test/java/org/apache/hadoop/mapreduce/lib/output/TestFileOutputCommitter.java +++ b/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/test/java/org/apache/hadoop/mapreduce/lib/output/TestFileOutputCommitter.java @@ -40,6 +40,7 @@ import org.apache.hadoop.fs.FileSystem; import org.apache.hadoop.fs.FileUtil; import org.apache.hadoop.fs.Path; import org.apache.hadoop.fs.RawLocalFileSystem; +import org.apache.hadoop.io.IOUtils; import org.apache.hadoop.io.LongWritable; import org.apache.hadoop.io.MapFile; import org.apache.hadoop.io.NullWritable; @@ -526,16 +527,15 @@ public class TestFileOutputCommitter { // Ensure getReaders call works and also ignores // hidden filenames (_ or . prefixes) + MapFile.Reader[] readers = {}; try { - MapFileOutputFormat.getReaders(outDir, conf); - } catch (Exception e) { - fail("Fail to read from MapFileOutputFormat: " + e); - e.printStackTrace(); + readers = MapFileOutputFormat.getReaders(outDir, conf); + // validate output + validateMapFileOutputContent(FileSystem.get(job.getConfiguration()), outDir); + } finally { + IOUtils.cleanupWithLogger(null, readers); + FileUtil.fullyDelete(new File(outDir.toString())); } - - // validate output - validateMapFileOutputContent(FileSystem.get(job.getConfiguration()), outDir); - FileUtil.fullyDelete(new File(outDir.toString())); } @Test --------------------------------------------------------------------- To unsubscribe, e-mail: common-commits-unsubscr...@hadoop.apache.org For additional commands, e-mail: common-commits-h...@hadoop.apache.org