diff --git a/ql/src/java/org/apache/hadoop/hive/ql/optimizer/calcite/translator/PlanModifierForASTConv.java b/ql/src/java/org/apache/hadoop/hive/ql/optimizer/calcite/translator/PlanModifierForASTConv.java index 5cd3a06..156d1ea 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/optimizer/calcite/translator/PlanModifierForASTConv.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/optimizer/calcite/translator/PlanModifierForASTConv.java @@ -187,7 +187,13 @@ public static RelNode renameTopLevelSelectInResultSchema(final RelNode rootRel, List newSelAliases = new ArrayList(); String colAlias; for (int i = 0; i < rootChildExps.size(); i++) { - colAlias = resultSchema.get(i).getName(); + String name = resultSchema.get(i).getName(); + if(name.contains(".")){ + colAlias = name.split("\\.")[1]; + } + else{ + colAlias = name; + } if (colAlias.startsWith("_")) { colAlias = colAlias.substring(1); }