commit 95ce6f393322dc97d2d80404437952fe32943d8f
author buyingyi <buyingyi@123451ca-8445-de46-9d55-352943316053> Wed Jan 18 09:08:40 2012 +0000
committer buyingyi <buyingyi@123451ca-8445-de46-9d55-352943316053> Wed Jan 18 09:08:40 2012 +0000
tree e8e3bdaaad2465dafb316381b987124662b74e4a
parent 26252db8d584eec53b1f232d74d92daaff0a8124

add explicit system.gc() call at the beginning of merge phase

git-svn-id: https://hyracks.googlecode.com/svn/branches/aggregators_dev_next@982 123451ca-8445-de46-9d55-352943316053

hyracks-dataflow-std/src/main/java/edu/uci/ics/hyracks/dataflow/std/group/ExternalGroupOperatorDescriptor.java

diff --git a/hyracks-dataflow-std/src/main/java/edu/uci/ics/hyracks/dataflow/std/group/ExternalGroupOperatorDescriptor.java b/hyracks-dataflow-std/src/main/java/edu/uci/ics/hyracks/dataflow/std/group/ExternalGroupOperatorDescriptor.java
index 0cc47b8..2483470 100644
--- a/hyracks-dataflow-std/src/main/java/edu/uci/ics/hyracks/dataflow/std/group/ExternalGroupOperatorDescriptor.java
+++ b/hyracks-dataflow-std/src/main/java/edu/uci/ics/hyracks/dataflow/std/group/ExternalGroupOperatorDescriptor.java
@@ -194,7 +194,7 @@
 
                 @Override
                 public void fail() throws HyracksDataException {
-
+                    throw new HyracksDataException("failed");
                 }
 
                 @Override
@@ -316,7 +316,12 @@
                                     gTable.sortFrames();
                                 gTable.flushFrames(writer, false);
                             }
+                            gTable = null;
+                            aggState = null;
+                            System.gc();
                         } else {
+                            aggState = null;
+                            System.gc();
                             runs = new LinkedList<RunFileReader>(runs);
                             inFrames = new ArrayList<ByteBuffer>();
                             outFrame = ctx.allocateFrame();