commit 442bbd030bf4c4a5db3ae1e6e050e46fcda6fa7e
author buyingyi <buyingyi@123451ca-8445-de46-9d55-352943316053> Fri May 20 08:03:38 2011 +0000
committer buyingyi <buyingyi@123451ca-8445-de46-9d55-352943316053> Fri May 20 08:03:38 2011 +0000
tree 541cd07dea50f334f47453ca8e900be6424e0c5f
parent 95e0f03c6521dd28fa6af5dab72ad763722fe133

fix the memSize issue in nested loop join

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

hyracks-dataflow-std/src/main/java/edu/uci/ics/hyracks/dataflow/std/join/NestedLoopJoin.java

diff --git a/hyracks-dataflow-std/src/main/java/edu/uci/ics/hyracks/dataflow/std/join/NestedLoopJoin.java b/hyracks-dataflow-std/src/main/java/edu/uci/ics/hyracks/dataflow/std/join/NestedLoopJoin.java
index 105a344..ba68caa 100644
--- a/hyracks-dataflow-std/src/main/java/edu/uci/ics/hyracks/dataflow/std/join/NestedLoopJoin.java
+++ b/hyracks-dataflow-std/src/main/java/edu/uci/ics/hyracks/dataflow/std/join/NestedLoopJoin.java
@@ -130,7 +130,8 @@
     }
 
     public void closeJoin(IFrameWriter writer) throws HyracksDataException {
-        for (ByteBuffer outBuffer : outBuffers) {
+        for (int i=0; i<currentMemSize; i++) {
+            ByteBuffer outBuffer = outBuffers.get(i);
             runFileReader = runFileWriter.createReader();
             runFileReader.open();
             while (runFileReader.nextFrame(innerBuffer)) {