diff --git a/ql/src/java/org/apache/hadoop/hive/ql/optimizer/DynamicPartitionPruningOptimization.java b/ql/src/java/org/apache/hadoop/hive/ql/optimizer/DynamicPartitionPruningOptimization.java index eca5a8b323..1dde26177f 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/optimizer/DynamicPartitionPruningOptimization.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/optimizer/DynamicPartitionPruningOptimization.java @@ -492,6 +492,9 @@ private void generateEventOperatorPlan(DynamicListContext ctx, ParseContext pars SelectDesc select = new SelectDesc(keyExprs, outputNames); SelectOperator selectOp = (SelectOperator) OperatorFactory.getAndMakeChild(select, new RowSchema(selectColInfos), parentOfRS); + Map selectColumnExprMap = new HashMap<>(); + selectColumnExprMap.put(outputNames.get(0), key); + selectOp.setColumnExprMap(selectColumnExprMap); // do a group by on the list to dedup float groupByMemoryUsage =