hadoop-mapreduce-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tomwh...@apache.org
Subject svn commit: r956779 - in /hadoop/mapreduce/trunk: CHANGES.txt src/java/org/apache/hadoop/mapreduce/jobhistory/JobHistory.java src/tools/org/apache/hadoop/tools/DistCp.java
Date Tue, 22 Jun 2010 06:06:29 GMT
Author: tomwhite
Date: Tue Jun 22 06:06:29 2010
New Revision: 956779

URL: http://svn.apache.org/viewvc?rev=956779&view=rev
Log:
MAPREDUCE-1885. Trunk compilation is broken because of FileSystem api change in HADOOP-6826.
Contributed by Ravi Gummadi.

Modified:
    hadoop/mapreduce/trunk/CHANGES.txt
    hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/JobHistory.java
    hadoop/mapreduce/trunk/src/tools/org/apache/hadoop/tools/DistCp.java

Modified: hadoop/mapreduce/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/CHANGES.txt?rev=956779&r1=956778&r2=956779&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/CHANGES.txt (original)
+++ hadoop/mapreduce/trunk/CHANGES.txt Tue Jun 22 06:06:29 2010
@@ -1574,3 +1574,7 @@ Release 0.21.0 - Unreleased
     (Corinne Chandel via amareshwari)
 
     MAPREDUCE-1880. Fix BigDecimal.divide(..) in the pi example.  (szetszwo)
+
+    MAPREDUCE-1885. Revert FileSystem create method that takes CreateFlags
+    (MapReduce part of HADOOP-6826). (Ravi Gummadi via tomwhite)
+

Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/JobHistory.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/JobHistory.java?rev=956779&r1=956778&r2=956779&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/JobHistory.java
(original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/JobHistory.java
Tue Jun 22 06:06:29 2010
@@ -276,8 +276,7 @@ public class JobHistory {
   
     FSDataOutputStream out = logDirFs.create(logFile, 
         new FsPermission(JobHistory.HISTORY_FILE_PERMISSION),
-        EnumSet.of(CreateFlag.OVERWRITE), 
-        defaultBufferSize, 
+        true, defaultBufferSize, 
         logDirFs.getDefaultReplication(), 
         jobHistoryBlockSize, null);
   
@@ -296,8 +295,7 @@ public class JobHistory {
         if (!logDirFs.exists(logDirConfPath)) {
           jobFileOut = logDirFs.create(logDirConfPath,
               new FsPermission(JobHistory.HISTORY_FILE_PERMISSION),
-              EnumSet.of(CreateFlag.OVERWRITE),
-              defaultBufferSize,
+              true, defaultBufferSize,
               logDirFs.getDefaultReplication(),
               logDirFs.getDefaultBlockSize(), null);
           jobConf.writeXml(jobFileOut);

Modified: hadoop/mapreduce/trunk/src/tools/org/apache/hadoop/tools/DistCp.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/tools/org/apache/hadoop/tools/DistCp.java?rev=956779&r1=956778&r2=956779&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/tools/org/apache/hadoop/tools/DistCp.java (original)
+++ hadoop/mapreduce/trunk/src/tools/org/apache/hadoop/tools/DistCp.java Tue Jun 22 06:06:29
2010
@@ -382,7 +382,7 @@ public class DistCp implements Tool {
           srcstat.getReplication(): destFileSys.getDefaultReplication();
       long blockSize = preseved.contains(FileAttribute.BLOCK_SIZE)?
           srcstat.getBlockSize(): destFileSys.getDefaultBlockSize();
-      return destFileSys.create(f, permission, EnumSet.of(CreateFlag.OVERWRITE), sizeBuf,
replication,
+      return destFileSys.create(f, permission, true, sizeBuf, replication,
           blockSize, reporter);
     }
 



Mime
View raw message