Author: todd
Date: Sat Dec  3 01:49:08 2011
New Revision: 1209823

URL: http://svn.apache.org/viewvc?rev=1209823&view=rev
Log:
HADOOP-7879. DistributedFileSystem#createNonRecursive should also 
incrementWriteOps statistics. Contributed by Jon Hsieh.

Modified:
    hadoop/common/branches/branch-1/CHANGES.txt
    
hadoop/common/branches/branch-1/src/hdfs/org/apache/hadoop/hdfs/DistributedFileSystem.java

Modified: hadoop/common/branches/branch-1/CHANGES.txt
URL: 
http://svn.apache.org/viewvc/hadoop/common/branches/branch-1/CHANGES.txt?rev=1209823&r1=1209822&r2=1209823&view=diff
==============================================================================
--- hadoop/common/branches/branch-1/CHANGES.txt (original)
+++ hadoop/common/branches/branch-1/CHANGES.txt Sat Dec  3 01:49:08 2011
@@ -55,6 +55,9 @@ Release 1.1.0 - unreleased
     HADOOP-7870. fix SequenceFile#createWriter with boolean
     createParent arg to respect createParent. (Jon Hsieh via eli)
 
+    HADOOP-7879. DistributedFileSystem#createNonRecursive should also
+    incrementWriteOps statistics. (Jon Hsieh via todd)
+
   IMPROVEMENTS
 
     MAPREDUCE-3008. [Gridmix] Improve cumulative CPU usage emulation for 

Modified: 
hadoop/common/branches/branch-1/src/hdfs/org/apache/hadoop/hdfs/DistributedFileSystem.java
URL: 
http://svn.apache.org/viewvc/hadoop/common/branches/branch-1/src/hdfs/org/apache/hadoop/hdfs/DistributedFileSystem.java?rev=1209823&r1=1209822&r2=1209823&view=diff
==============================================================================
--- 
hadoop/common/branches/branch-1/src/hdfs/org/apache/hadoop/hdfs/DistributedFileSystem.java
 (original)
+++ 
hadoop/common/branches/branch-1/src/hdfs/org/apache/hadoop/hdfs/DistributedFileSystem.java
 Sat Dec  3 01:49:08 2011
@@ -194,7 +194,7 @@ public class DistributedFileSystem exten
       boolean overwrite,
       int bufferSize, short replication, long blockSize, 
       Progressable progress) throws IOException {
-
+    statistics.incrementWriteOps(1);
     return new FSDataOutputStream
         (dfs.create(getPathName(f), permission, 
                     overwrite, false, replication, blockSize, progress, 
bufferSize), 


Reply via email to