hadoop-svn/progressReporter.patch

   1 Index: src/core/org/apache/hadoop/fs/kfs/KFSOutputStream.java
   2 ===================================================================
   3 --- src/core/org/apache/hadoop/fs/kfs/KFSOutputStream.java      (revision 764287)
   4 +++ src/core/org/apache/hadoop/fs/kfs/KFSOutputStream.java      (working copy)
   5 @@ -73,7 +73,9 @@
   6          }
   7
   8          // touch the progress before going into KFS since the call can block
   9 -        progressReporter.progress();
  10 +        if (progressReporter != null) {
  11 +            progressReporter.progress();
  12 +        }
  13          kfsChannel.write(ByteBuffer.wrap(b, off, len));
  14      }
  15
  16 @@ -82,7 +84,9 @@
  17              throw new IOException("File closed");
  18          }
  19          // touch the progress before going into KFS since the call can block
  20 -        progressReporter.progress();
  21 +        if (progressReporter != null) {
  22 +            progressReporter.progress();
  23 +        }
  24          kfsChannel.sync();
  25      }
  26