diff --git a/ql/src/java/org/apache/hadoop/hive/ql/optimizer/optiq/translator/JoinCondTypeCheckProcFactory.java b/ql/src/java/org/apache/hadoop/hive/ql/optimizer/optiq/translator/JoinCondTypeCheckProcFactory.java index 38156c6..89c57b9 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/optimizer/optiq/translator/JoinCondTypeCheckProcFactory.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/optimizer/optiq/translator/JoinCondTypeCheckProcFactory.java @@ -103,7 +103,8 @@ public Object process(Node nd, Stack stack, NodeProcessorCtx procCtx, } else if (hasTableAlias(ctx, tableOrCol, expr)) { return null; } else { - throw new SemanticException(ErrorMsg.INVALID_COLUMN.getMsg(expr)); + // Qualified column access for which table was not found + throw new SemanticException(ErrorMsg.INVALID_TABLE_ALIAS.getMsg(expr)); } } @@ -143,7 +144,7 @@ private static ColumnInfo getColInfo(JoinTypeCheckCtx ctx, String tabName, Strin /** * Factory method to get ColumnExprProcessor. - * + * * @return ColumnExprProcessor. */ @Override @@ -305,7 +306,7 @@ private static boolean comparisonUDFargsRefersToBothInput(GenericUDFBaseCompare /** * Factory method to get DefaultExprProcessor. - * + * * @return DefaultExprProcessor. */ @Override