diff --git ql/src/java/org/apache/hadoop/hive/ql/parse/CalcitePlanner.java ql/src/java/org/apache/hadoop/hive/ql/parse/CalcitePlanner.java index 3b8ade5..6a15bf6 100644 --- ql/src/java/org/apache/hadoop/hive/ql/parse/CalcitePlanner.java +++ ql/src/java/org/apache/hadoop/hive/ql/parse/CalcitePlanner.java @@ -2429,6 +2429,9 @@ private RelNode genSelectRelNode(List calciteColLst, RowResolver out_rw */ tmpColAlias = qualifiedColNames[1]; + if (tmpColAlias.contains(".") || tmpColAlias.contains(":")) { + tmpColAlias = cInfo.getInternalName(); + } // Prepend column names with '_o_' if it starts with '_c' /* * Hive treats names that start with '_c' as internalNames; so change