svn commit: r654345 - in /incubator/pig/trunk: CHANGES.txt src/org/apache/pig/backend/hadoop/streaming/HadoopExecutableManager.java

[olga]

Author: olga
Date: Wed May  7 17:29:19 2008
New Revision: 654345

URL: http://svn.apache.org/viewvc?rev=654345&view=rev
Log:
PIG-232: fix for reported number of output records

Modified:
    incubator/pig/trunk/CHANGES.txt
    
incubator/pig/trunk/src/org/apache/pig/backend/hadoop/streaming/HadoopExecutableManager.java

Modified: incubator/pig/trunk/CHANGES.txt
URL: 
http://svn.apache.org/viewvc/incubator/pig/trunk/CHANGES.txt?rev=654345&r1=654344&r2=654345&view=diff
==============================================================================
--- incubator/pig/trunk/CHANGES.txt (original)
+++ incubator/pig/trunk/CHANGES.txt Wed May  7 17:29:19 2008
@@ -283,3 +283,5 @@
        PIG-202: Fix Order by so that user provided comparator func is used for 
quantile determination (kali via gates).
 
     PIG-231: validation for ship, cache, and skippath
+
+    PIG-232: fix for number of output records when BinaryStirage is used

Modified: 
incubator/pig/trunk/src/org/apache/pig/backend/hadoop/streaming/HadoopExecutableManager.java
URL: 
http://svn.apache.org/viewvc/incubator/pig/trunk/src/org/apache/pig/backend/hadoop/streaming/HadoopExecutableManager.java?rev=654345&r1=654344&r2=654345&view=diff
==============================================================================
--- 
incubator/pig/trunk/src/org/apache/pig/backend/hadoop/streaming/HadoopExecutableManager.java
 (original)
+++ 
incubator/pig/trunk/src/org/apache/pig/backend/hadoop/streaming/HadoopExecutableManager.java
 Wed May  7 17:29:19 2008
@@ -230,7 +230,10 @@
         List<HandleSpec> outputSpecs = command.getHandleSpecs(Handle.OUTPUT);
         HandleSpec outputSpec = 
             (outputSpecs != null) ? outputSpecs.get(0) : null;
-        processError("\nOutput records: " + outputRecords);
+        if (outputSpec == null || 
+            !outputSpec.getSpec().contains("BinaryStorage")) {
+            processError("\nOutput records: " + outputRecords);
+        }
         processError("\nOutput bytes: " + outputBytes + " bytes " +
                      ((outputSpec != null) ? 
                          "(" + outputSpec.getName() + " using " +