diff --git ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorMapJoinOperator.java ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorMapJoinOperator.java index abffd5a..9b3b251 100644 --- ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorMapJoinOperator.java +++ ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorMapJoinOperator.java @@ -116,10 +116,14 @@ public VectorMapJoinOperator (VectorizationContext vContext, OperatorDesc conf) List outColNames = desc.getOutputColumnNames(); int outputColumnIndex = 0; + + Map cMap = vContext.getColumnMap(); for(byte alias:order) { for(ExprNodeDesc expr: exprs.get(alias)) { String columnName = outColNames.get(outputColumnIndex); - vContext.addOutputColumn(columnName, expr.getTypeString()); + if (!cMap.containsKey(columnName)) { + vContext.addOutputColumn(columnName, expr.getTypeString()); + } ++outputColumnIndex; } }