diff --git a/ql/src/java/org/apache/hadoop/hive/ql/optimizer/calcite/translator/HiveOpConverter.java b/ql/src/java/org/apache/hadoop/hive/ql/optimizer/calcite/translator/HiveOpConverter.java index 3afcb54..81c67a8 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/optimizer/calcite/translator/HiveOpConverter.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/optimizer/calcite/translator/HiveOpConverter.java @@ -282,6 +282,11 @@ OpAttr visit(HiveProject projectRel) throws SemanticException { projectRel.getChildExps(), exprCols, exprNames, inputOpAf); SelectOperator selOp = (SelectOperator) OperatorFactory.getAndMakeChild(sd, new RowSchema( colInfoVColPair.getKey()), inputOpAf.inputs.get(0)); + Map colExprMap = new HashMap(); + for (int i = 0; i < exprCols.size(); i++) { + colExprMap.put(exprNames.get(i), exprCols.get(i)); + } + selOp.setColumnExprMap(colExprMap); if (LOG.isDebugEnabled()) { LOG.debug("Generated " + selOp + " with row schema: [" + selOp.getSchema() + "]");