commit 3789e229866dafe99f35b007a3b6d6395d26d9a2
author jarodwen <jarodwen@123451ca-8445-de46-9d55-352943316053> Fri Mar 02 19:31:44 2012 +0000
committer jarodwen <jarodwen@123451ca-8445-de46-9d55-352943316053> Fri Mar 02 19:31:44 2012 +0000
tree 218ee7e5c1294cf9284e0ccff7cff04073638bc9
parent 49457c34c182c961acc66fc407786e0aafc7b21d

Fixed an incorrect initialization of the priority queue in external group operator. The bug may cause incorrect merging results. 

git-svn-id: https://hyracks.googlecode.com/svn/branches/hyracks_dev_next@1266 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 1cab78d..58f9ffa 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
@@ -382,7 +382,8 @@
                          */
                         int[] tupleIndices = new int[runNumber];
 
-                        for (int runIndex = runNumber - 1; runIndex >= 0; runIndex--) {
+                        for (int i = 0; i < runNumber; i++) {
+                            int runIndex = topTuples.peek().getRunid();
                             tupleIndices[runIndex] = 0;
                             // Load the run file
                             runFileReaders[runIndex] = runs.get(runIndex);