diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorGroupKeyHelper.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorGroupKeyHelper.java index 64706ad..4b1c4d2 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorGroupKeyHelper.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorGroupKeyHelper.java @@ -67,7 +67,7 @@ public void copyGroupKey(VectorizedRowBatch inputBatch, VectorizedRowBatch outpu for(int i = 0; i< longIndices.length; ++i) { final int columnIndex = outputColumnNums[longIndices[i]]; LongColumnVector inputColumnVector = (LongColumnVector) inputBatch.cols[columnIndex]; - LongColumnVector outputColumnVector = (LongColumnVector) outputBatch.cols[columnIndex]; + LongColumnVector outputColumnVector = (LongColumnVector) outputBatch.cols[longIndices[i]]; // This vectorized code pattern says: // If the input batch has no nulls at all (noNulls is true) OR @@ -93,7 +93,7 @@ public void copyGroupKey(VectorizedRowBatch inputBatch, VectorizedRowBatch outpu for(int i=0;i