svn commit: r538631 - in /lucene/hadoop/trunk: CHANGES.txt src/java/org/apache/hadoop/filecache/DistributedCache.java

[to...@apache.org]

Author: tomwhite
Date: Wed May 16 08:40:51 2007
New Revision: 538631

URL: http://svn.apache.org/viewvc?view=rev&rev=538631
Log:
HADOOP-1340.  Set the replication factor of the MD5 file in the filecache to be the same as the replication factor of the original file.  Contributed by Dhruba Borthakur.

Modified:
    lucene/hadoop/trunk/CHANGES.txt
    lucene/hadoop/trunk/src/java/org/apache/hadoop/filecache/DistributedCache.java

Modified: lucene/hadoop/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/lucene/hadoop/trunk/CHANGES.txt?view=diff&rev=538631&r1=538630&r2=538631
==============================================================================
--- lucene/hadoop/trunk/CHANGES.txt (original)
+++ lucene/hadoop/trunk/CHANGES.txt Wed May 16 08:40:51 2007
@@ -14,6 +14,10 @@
   4. HADOOP-1342.  In aggregators, permit one to limit the number of
      unique values per key.  (Runping Qi via cutting)
 
+  5. HADOOP-1340.  Set the replication factor of the MD5 file in the filecache
+     to be the same as the replication factor of the original file.
+     (Dhruba Borthakur via tomwhite.)
+
 
 Branch 0.13 (unreleased changes)
 

Modified: lucene/hadoop/trunk/src/java/org/apache/hadoop/filecache/DistributedCache.java
URL: http://svn.apache.org/viewvc/lucene/hadoop/trunk/src/java/org/apache/hadoop/filecache/DistributedCache.java?view=diff&rev=538631&r1=538630&r2=538631
==============================================================================
--- lucene/hadoop/trunk/src/java/org/apache/hadoop/filecache/DistributedCache.java (original)
+++ lucene/hadoop/trunk/src/java/org/apache/hadoop/filecache/DistributedCache.java Wed May 16 08:40:51 2007
@@ -320,7 +320,8 @@
       fsStream.close();
       digest = md5.digest();
 
-      FSDataOutputStream out = fileSystem.create(md5File);
+      short replication = fileSystem.getReplication(filePath);
+      FSDataOutputStream out = fileSystem.create(md5File, replication);
       out.write(digest);
       out.close();
     } else {