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

[olga]

Author: olga
Date: Wed May  7 18:04:18 2008
New Revision: 654364

URL: http://svn.apache.org/viewvc?rev=654364&view=rev
Log:
PIG-232: fix for reported number of input rows

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=654364&r1=654363&r2=654364&view=diff
==============================================================================
--- incubator/pig/trunk/CHANGES.txt (original)
+++ incubator/pig/trunk/CHANGES.txt Wed May  7 18:04:18 2008
@@ -282,6 +282,10 @@
 
        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-231: validation for ship, cache, and skippath  (acmurthy via olgan)
 
     PIG-232: fix for number of output records when BinaryStirage is used
+    (acmurthy via olgan)
+
+    PIG-232: fix for number of input records when BinaryStirage is used
+    (acmurthy via olgan)

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=654364&r1=654363&r2=654364&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 18:04:18 2008
@@ -220,7 +220,10 @@
         List<HandleSpec> inputSpecs = command.getHandleSpecs(Handle.INPUT);
         HandleSpec inputSpec = 
             (inputSpecs != null) ? inputSpecs.get(0) : null;
-        processError("\nInput records: " + inputRecords);
+        if (inputSpec == null || 
+            !inputSpec.getSpec().contains("BinaryStorage")) {
+            processError("\nInput records: " + inputRecords);
+        }
         processError("\nInput bytes: " + inputBytes + " bytes " +
                     ((inputSpec != null) ? 
                             "(" + inputSpec.getName() + " using " +