You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by mm...@apache.org on 2018/01/27 14:17:34 UTC
hive git commit: HIVE-18551: Vectorization: VectorMapOperator tries
to write too many vector columns for Hybrid Grace (Matt McCline,
reviewed by Teddy Choi)
Repository: hive
Updated Branches:
refs/heads/master 905d84e8f -> cebe012fe
HIVE-18551: Vectorization: VectorMapOperator tries to write too many vector columns for Hybrid Grace (Matt McCline, reviewed by Teddy Choi)
Project: http://git-wip-us.apache.org/repos/asf/hive/repo
Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/cebe012f
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/cebe012f
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/cebe012f
Branch: refs/heads/master
Commit: cebe012fe325f07056a919b738ed291b24305fa5
Parents: 905d84e
Author: Matt McCline <mm...@hortonworks.com>
Authored: Sat Jan 27 08:17:26 2018 -0600
Committer: Matt McCline <mm...@hortonworks.com>
Committed: Sat Jan 27 08:17:26 2018 -0600
----------------------------------------------------------------------
.../apache/hadoop/hive/ql/exec/vector/VectorMapJoinOperator.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hive/blob/cebe012f/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorMapJoinOperator.java
----------------------------------------------------------------------
diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorMapJoinOperator.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorMapJoinOperator.java
index f5c3cbe..a84bd72 100644
--- a/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorMapJoinOperator.java
+++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorMapJoinOperator.java
@@ -248,13 +248,14 @@ public class VectorMapJoinOperator extends VectorMapJoinBaseOperator {
super.spillBigTableRow(hybridHtContainer, actualRow);
}
+ // Only used by spillBigTableRow?
// Code borrowed from VectorReduceSinkOperator
private Object[] getRowObject(VectorizedRowBatch vrb, int rowIndex) throws HiveException {
int batchIndex = rowIndex;
if (vrb.selectedInUse) {
batchIndex = vrb.selected[rowIndex];
}
- for (int i = 0; i < vrb.projectionSize; i++) {
+ for (int i = 0; i < singleRow.length; i++) {
ColumnVector vectorColumn = vrb.cols[vrb.projectedColumns[i]];
if (vectorColumn != null) {
singleRow[i] = rowWriters[i].writeValue(vectorColumn, batchIndex);