svn commit: r686093 - in /incubator/pig/branches/types: CHANGES.txt src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/MRCompiler.java

[olga]

Author: olga
Date: Thu Aug 14 17:02:05 2008
New Revision: 686093

URL: http://svn.apache.org/viewvc?rev=686093&view=rev
Log:
PIG-378: fix for GENERATE + LIMIT

Modified:
    incubator/pig/branches/types/CHANGES.txt
    
incubator/pig/branches/types/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/MRCompiler.java

Modified: incubator/pig/branches/types/CHANGES.txt
URL: 
http://svn.apache.org/viewvc/incubator/pig/branches/types/CHANGES.txt?rev=686093&r1=686092&r2=686093&view=diff
==============================================================================
--- incubator/pig/branches/types/CHANGES.txt (original)
+++ incubator/pig/branches/types/CHANGES.txt Thu Aug 14 17:02:05 2008
@@ -151,3 +151,11 @@
     PIG-368: making JobConf available to Load/Store UDFs
 
     PIG-311: cross is broken
+
+    PIG-369: support for filter UDFs
+
+    PIG-375: support for implicit split
+
+    PIG-301: fix for order by descending
+
+    PIG-378: fix for GENERATE + LIMIT

Modified: 
incubator/pig/branches/types/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/MRCompiler.java
URL: 
http://svn.apache.org/viewvc/incubator/pig/branches/types/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/MRCompiler.java?rev=686093&r1=686092&r2=686093&view=diff
==============================================================================
--- 
incubator/pig/branches/types/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/MRCompiler.java
 (original)
+++ 
incubator/pig/branches/types/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/MRCompiler.java
 Thu Aug 14 17:02:05 2008
@@ -667,7 +667,7 @@
                     prj1.setOverloaded(true);
                     ep1.add(prj1);
                     eps1.add(ep1);
-                    flat1.add(false);
+                    flat1.add(true);
                     POForEach nfe1 = new POForEach(new OperatorKey(scope, nig
                             .getNextNodeId(scope)), 
op.getRequestedParallelism(), eps1,
                             flat1);