Author: olga
Date: Wed Nov 28 14:29:08 2007
New Revision: 599170

URL: http://svn.apache.org/viewvc?rev=599170&view=rev
Log:
PIG-31: second half of concurrent mode problem addressed

Modified:
    incubator/pig/trunk/CHANGES.txt
    incubator/pig/trunk/src/org/apache/pig/data/BigDataBag.java

Modified: incubator/pig/trunk/CHANGES.txt
URL: 
http://svn.apache.org/viewvc/incubator/pig/trunk/CHANGES.txt?rev=599170&r1=599169&r2=599170&view=diff
==============================================================================
--- incubator/pig/trunk/CHANGES.txt (original)
+++ incubator/pig/trunk/CHANGES.txt Wed Nov 28 14:29:08 2007
@@ -10,8 +10,6 @@
   OPTIMIZATIONS
 
   BUG FIXES
-        PIG-11 Add capability to search for jar file to register.
-
        PIG-24 Files that were incorrectly placed under test/reports have been
        removed.  ant clean now cleans test/reports.  (milindb via gates)
 
@@ -23,6 +21,11 @@
 
        PIG-17 integrated with Hadoop 0.15 (olgan@)
 
+    PIG-11 Add capability to search for jar file to register. (antmagna via
+       olgan)
+
        PIG-20 Added custom comparator functions for order by (phunt via gates)
 
-       PIG-33 Help was commented out - uncommented (olgan@)
+       PIG-33 Help was commented out - uncommented (olgan)
+
+       PIG-31: second half of concurrent mode problem addressed (olgan)

Modified: incubator/pig/trunk/src/org/apache/pig/data/BigDataBag.java
URL: 
http://svn.apache.org/viewvc/incubator/pig/trunk/src/org/apache/pig/data/BigDataBag.java?rev=599170&r1=599169&r2=599170&view=diff
==============================================================================
--- incubator/pig/trunk/src/org/apache/pig/data/BigDataBag.java (original)
+++ incubator/pig/trunk/src/org/apache/pig/data/BigDataBag.java Wed Nov 28 
14:29:08 2007
@@ -405,7 +405,11 @@
 
     @Override
     protected void finalize() throws Throwable {
-       clear();
+       //clear();
+        close();
+        while(!stores.isEmpty())
+            stores.removeFirst().delete();
+               
        super.finalize();
     }
     


Reply via email to