svn commit: r472283 - in /lucene/hadoop/trunk: CHANGES.txt src/contrib/streaming/src/java/org/apache/hadoop/streaming/PipeMapRed.java

[cutting]

Author: cutting
Date: Tue Nov  7 13:30:46 2006
New Revision: 472283

URL: http://svn.apache.org/viewvc?view=rev&rev=472283
Log:
HADOOP-645.  Fix a bug in contrib/streaming when -reducer is NONE.  Contributed 
by Dhruba.

Modified:
    lucene/hadoop/trunk/CHANGES.txt
    
lucene/hadoop/trunk/src/contrib/streaming/src/java/org/apache/hadoop/streaming/PipeMapRed.java

Modified: lucene/hadoop/trunk/CHANGES.txt
URL: 
http://svn.apache.org/viewvc/lucene/hadoop/trunk/CHANGES.txt?view=diff&rev=472283&r1=472282&r2=472283
==============================================================================
--- lucene/hadoop/trunk/CHANGES.txt (original)
+++ lucene/hadoop/trunk/CHANGES.txt Tue Nov  7 13:30:46 2006
@@ -13,6 +13,9 @@
  3. HADOOP-682.  Fix DFS format command to work correctly when
     configured with a non-existent directory. (Sanjay Dahiya via cutting)
 
+ 4. HADOOP-645.  Fix a bug in contrib/streaming when -reducer is NONE.
+    (Dhruba Borthakur via cutting) 
+
 
 Release 0.8.0 - 2006-11-03
 

Modified: 
lucene/hadoop/trunk/src/contrib/streaming/src/java/org/apache/hadoop/streaming/PipeMapRed.java
URL: 
http://svn.apache.org/viewvc/lucene/hadoop/trunk/src/contrib/streaming/src/java/org/apache/hadoop/streaming/PipeMapRed.java?view=diff&rev=472283&r1=472282&r2=472283
==============================================================================
--- 
lucene/hadoop/trunk/src/contrib/streaming/src/java/org/apache/hadoop/streaming/PipeMapRed.java
 (original)
+++ 
lucene/hadoop/trunk/src/contrib/streaming/src/java/org/apache/hadoop/streaming/PipeMapRed.java
 Tue Nov  7 13:30:46 2006
@@ -291,7 +291,6 @@
           }
           f = null;
       }
-      System.out.println("XXX2 argvSplit[0] = " + argvSplit[0]);
       logprintln("PipeMapRed exec " + Arrays.asList(argvSplit));
       logprintln("sideEffectURI_=" + sideEffectURI_);
 
@@ -580,9 +579,6 @@
           logprintln("closing " + sideEffectURI_);
           if (sideEffectOut_ != null) sideEffectOut_.close();
           logprintln("closed  " + sideEffectURI_);
-          if (sideEffectURI_.getScheme().equals("file")) {
-            logprintln("size  " + new File(sideEffectURI_).length());
-          }
           if (useSingleSideOutputURI_) {
             // With sideEffectPath_ we wrote in-place. 
             // Possibly a named pipe set up by user or a socket.