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 02:29:19 UTC
svn commit: r654345 - in /incubator/pig/trunk: CHANGES.txt
src/org/apache/pig/backend/hadoop/streaming/HadoopExecutableManager.java
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 " +