You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pig.apache.org by th...@apache.org on 2011/01/21 22:08:51 UTC

svn commit: r1062030 - in /pig/branches/branch-0.8: CHANGES.txt src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigCombiner.java

Author: thejas
Date: Fri Jan 21 21:08:50 2011
New Revision: 1062030

URL: http://svn.apache.org/viewvc?rev=1062030&view=rev
Log:
PIG-1815: pig task retains used instances of PhysicalPlan 

Modified:
    pig/branches/branch-0.8/CHANGES.txt
    pig/branches/branch-0.8/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigCombiner.java

Modified: pig/branches/branch-0.8/CHANGES.txt
URL: http://svn.apache.org/viewvc/pig/branches/branch-0.8/CHANGES.txt?rev=1062030&r1=1062029&r2=1062030&view=diff
==============================================================================
--- pig/branches/branch-0.8/CHANGES.txt (original)
+++ pig/branches/branch-0.8/CHANGES.txt Fri Jan 21 21:08:50 2011
@@ -213,6 +213,8 @@ PIG-1309: Map-side Cogroup (ashutoshc)
 
 BUG FIXES
 
+PIG-1815: pig task retains used instances of PhysicalPlan (thejas)
+
 PIG-1785: New logical plan: uid conflict in flattened fields (daijy)
 
 PIG-1787: Error in logical plan generated (daijy)

Modified: pig/branches/branch-0.8/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigCombiner.java
URL: http://svn.apache.org/viewvc/pig/branches/branch-0.8/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigCombiner.java?rev=1062030&r1=1062029&r2=1062030&view=diff
==============================================================================
--- pig/branches/branch-0.8/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigCombiner.java (original)
+++ pig/branches/branch-0.8/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigCombiner.java Fri Jan 21 21:08:50 2011
@@ -246,11 +246,19 @@ public class PigCombiner {
         
         /**
          * Will be called once all the intermediate keys and values are
-         * processed. So right place to stop the reporter thread.
+         * processed.
+         * cleanup references to the PhysicalPlan
          */
         @Override        
         protected void cleanup(Context context) throws IOException, InterruptedException {
             super.cleanup(context);
+            leaf = null;
+            pack = null;
+            pigReporter.setRep(null);
+            pigReporter = null;
+            pigContext = null;
+            roots = null;
+            cp = null;
         }
 
         /**