You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by se...@apache.org on 2014/10/30 21:23:50 UTC
svn commit: r1635603 -
/hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/parse/SemanticAnalyzer.java
Author: sershe
Date: Thu Oct 30 20:23:49 2014
New Revision: 1635603
URL: http://svn.apache.org/r1635603
Log:
HIVE-8654 : CBO: parquet_ctas test returns incorrect results (Sergey Shelukhin, reviewed by Ashutosh Chauhan)
Modified:
hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/parse/SemanticAnalyzer.java
Modified: hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/parse/SemanticAnalyzer.java
URL: http://svn.apache.org/viewvc/hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/parse/SemanticAnalyzer.java?rev=1635603&r1=1635602&r2=1635603&view=diff
==============================================================================
--- hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/parse/SemanticAnalyzer.java (original)
+++ hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/parse/SemanticAnalyzer.java Thu Oct 30 20:23:49 2014
@@ -6263,8 +6263,10 @@ public class SemanticAnalyzer extends Ba
if (!("".equals(nm[0])) && nm[1] != null) {
colName = unescapeIdentifier(colInfo.getAlias()).toLowerCase(); // remove ``
}
- String ctasColName = fixCtasColumnName(colName, colInfo, inputRR);
- col.setName(ctasColName);
+ if (runCBO) {
+ colName = fixCtasColumnName(colName);
+ }
+ col.setName(colName);
col.setType(colInfo.getType().getTypeName());
field_schemas.add(col);
}
@@ -6442,7 +6444,7 @@ public class SemanticAnalyzer extends Ba
return output;
}
- private static String fixCtasColumnName(String colName, ColumnInfo colInfo, RowResolver rr) {
+ private static String fixCtasColumnName(String colName) {
int lastDot = colName.lastIndexOf('.');
if (lastDot < 0) return colName; // alias is not fully qualified
String nqColumnName = colName.substring(lastDot + 1);