diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/ColumnInfo.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/ColumnInfo.java index 020d7f3..b21d9c3 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/exec/ColumnInfo.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/ColumnInfo.java @@ -234,7 +234,11 @@ public boolean internalEquals(ColumnInfo dest) { (isHiddenVirtualCol != dest.isHiddenVirtualCol())) { return false; } - + // if the tabAlias are different, make them the same for collecting correct + // statistics. + if (!checkEquals(tabAlias, dest.tabAlias)) { + dest.setTabAlias(tabAlias); + } return true; }