You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pig.apache.org by ol...@apache.org on 2008/05/08 03:04:18 UTC
svn commit: r654364 - in /incubator/pig/trunk: CHANGES.txt
src/org/apache/pig/backend/hadoop/streaming/HadoopExecutableManager.java
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 " +