Explorar o código

svn merge -c 1359252 FIXES: MAPREDUCE-4402. TestFileInputFormat fails intermittently (Jason Lowe via bobby)

git-svn-id: https://svn.apache.org/repos/asf/hadoop/common/branches/branch-2@1359253 13f79535-47bb-0310-9956-ffa450edef68
Robert Joseph Evans %!s(int64=13) %!d(string=hai) anos
pai
achega
2353571c64

+ 3 - 0
hadoop-mapreduce-project/CHANGES.txt

@@ -532,6 +532,9 @@ Release 0.23.3 - UNRELEASED
     space due to org.apache.hadoop.fs.LocalDirAllocator.contexts (Devaraj K
     space due to org.apache.hadoop.fs.LocalDirAllocator.contexts (Devaraj K
     via bobby)
     via bobby)
 
 
+    MAPREDUCE-4402. TestFileInputFormat fails intermittently (Jason Lowe via
+    bobby)
+
 Release 0.23.2 - UNRELEASED
 Release 0.23.2 - UNRELEASED
 
 
   INCOMPATIBLE CHANGES
   INCOMPATIBLE CHANGES

+ 5 - 2
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-jobclient/src/test/java/org/apache/hadoop/mapred/TestFileInputFormat.java

@@ -97,13 +97,16 @@ public class TestFileInputFormat extends TestCase {
   private void createInputs(FileSystem fs, Path inDir, String fileName)
   private void createInputs(FileSystem fs, Path inDir, String fileName)
   throws IOException {
   throws IOException {
     // create a multi-block file on hdfs
     // create a multi-block file on hdfs
-    DataOutputStream out = fs.create(new Path(inDir, fileName), true, 4096,
-                                     (short) 2, 512, null);
+    Path path = new Path(inDir, fileName);
+    final short replication = 2;
+    DataOutputStream out = fs.create(path, true, 4096,
+                                     replication, 512, null);
     for(int i=0; i < 1000; ++i) {
     for(int i=0; i < 1000; ++i) {
       out.writeChars("Hello\n");
       out.writeChars("Hello\n");
     }
     }
     out.close();
     out.close();
     System.out.println("Wrote file");
     System.out.println("Wrote file");
+    DFSTestUtil.waitReplication(fs, path, replication);
   }
   }
 
 
   public void testNumInputs() throws Exception {
   public void testNumInputs() throws Exception {