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;
}
/**