diff --git a/ql/src/java/org/apache/hadoop/hive/ql/optimizer/calcite/translator/ASTConverter.java b/ql/src/java/org/apache/hadoop/hive/ql/optimizer/calcite/translator/ASTConverter.java index ee21a1eeb2..c2893eebdf 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/optimizer/calcite/translator/ASTConverter.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/optimizer/calcite/translator/ASTConverter.java @@ -416,6 +416,7 @@ private QueryBlockInfo convertSource(RelNode r) throws CalciteSemanticException type = join.getJoinType(); } ast = ASTBuilder.join(right.ast, left.ast, type, cond); + s = new Schema(right.schema, left.schema); } else { ast = ASTBuilder.join(left.ast, right.ast, join.getJoinType(), cond); }