Index: ql/src/test/results/clientpositive/join0.q.out =================================================================== --- ql/src/test/results/clientpositive/join0.q.out (revision 725562) +++ ql/src/test/results/clientpositive/join0.q.out (working copy) @@ -1,8 +1,9 @@ ABSTRACT SYNTAX TREE: - (TOK_QUERY (TOK_FROM (TOK_JOIN (TOK_SUBQUERY (TOK_QUERY (TOK_FROM (TOK_TABREF src)) (TOK_INSERT (TOK_DESTINATION (TOK_DIR TOK_TMP_FILE)) (TOK_SELECT (TOK_SELEXPR TOK_ALLCOLREF)) (TOK_WHERE (< (TOK_COLREF src key) 10)))) src1) (TOK_SUBQUERY (TOK_QUERY (TOK_FROM (TOK_TABREF src)) (TOK_INSERT (TOK_DESTINATION (TOK_DIR TOK_TMP_FILE)) (TOK_SELECT (TOK_SELEXPR TOK_ALLCOLREF)) (TOK_WHERE (< (TOK_COLREF src key) 10)))) src2))) (TOK_INSERT (TOK_DESTINATION (TOK_DIR TOK_TMP_FILE)) (TOK_SELECT (TOK_SELEXPR TOK_ALLCOLREF)))) + (TOK_QUERY (TOK_FROM (TOK_JOIN (TOK_SUBQUERY (TOK_QUERY (TOK_FROM (TOK_TABREF src)) (TOK_INSERT (TOK_DESTINATION (TOK_DIR TOK_TMP_FILE)) (TOK_SELECT (TOK_SELEXPR TOK_ALLCOLREF)) (TOK_WHERE (< (TOK_COLREF src key) 10)))) src1) (TOK_SUBQUERY (TOK_QUERY (TOK_FROM (TOK_TABREF src)) (TOK_INSERT (TOK_DESTINATION (TOK_DIR TOK_TMP_FILE)) (TOK_SELECT (TOK_SELEXPR TOK_ALLCOLREF)) (TOK_WHERE (< (TOK_COLREF src key) 10)))) src2))) (TOK_INSERT (TOK_DESTINATION (TOK_DIR TOK_TMP_FILE)) (TOK_SELECT (TOK_SELEXPR (TOK_COLREF src1 key) k1) (TOK_SELEXPR (TOK_COLREF src1 value) v1) (TOK_SELEXPR (TOK_COLREF src2 key) k2) (TOK_SELEXPR (TOK_COLREF src2 value) v2)) (TOK_SORTBY (TOK_TABSORTCOLNAMEASC k1) (TOK_TABSORTCOLNAMEASC v1) (TOK_TABSORTCOLNAMEASC k2) (TOK_TABSORTCOLNAMEASC v2)))) STAGE DEPENDENCIES: Stage-1 is a root stage + Stage-2 depends on stages: Stage-1 Stage-0 is a root stage STAGE PLANS: @@ -67,111 +68,145 @@ File Output Operator compressed: false table: - input format: org.apache.hadoop.mapred.TextInputFormat - output format: org.apache.hadoop.hive.ql.io.IgnoreKeyTextOutputFormat + input format: org.apache.hadoop.mapred.SequenceFileInputFormat + output format: org.apache.hadoop.mapred.SequenceFileOutputFormat + name: binary_table + Stage: Stage-2 + Map Reduce + Alias -> Map Operator Tree: + /tmp/hive-zshao/909665613/33076823.10002 + Reduce Output Operator + key expressions: + expr: 0 + type: string + expr: 1 + type: string + expr: 2 + type: string + expr: 3 + type: string + sort order: ++++ + tag: -1 + value expressions: + expr: 0 + type: string + expr: 1 + type: string + expr: 2 + type: string + expr: 3 + type: string + Reduce Operator Tree: + Extract + File Output Operator + compressed: false + table: + input format: org.apache.hadoop.mapred.TextInputFormat + output format: org.apache.hadoop.hive.ql.io.IgnoreKeyTextOutputFormat + Stage: Stage-0 Fetch Operator limit: -1 -9 val_9 0 val_0 -9 val_9 4 val_4 -9 val_9 8 val_8 -9 val_9 0 val_0 -9 val_9 0 val_0 -9 val_9 5 val_5 -9 val_9 2 val_2 -9 val_9 5 val_5 -9 val_9 9 val_9 -9 val_9 5 val_5 +0 val_0 0 val_0 +0 val_0 0 val_0 +0 val_0 0 val_0 +0 val_0 0 val_0 +0 val_0 0 val_0 +0 val_0 0 val_0 +0 val_0 0 val_0 +0 val_0 0 val_0 +0 val_0 0 val_0 +0 val_0 2 val_2 +0 val_0 2 val_2 +0 val_0 2 val_2 +0 val_0 4 val_4 +0 val_0 4 val_4 +0 val_0 4 val_4 +0 val_0 5 val_5 +0 val_0 5 val_5 +0 val_0 5 val_5 +0 val_0 5 val_5 +0 val_0 5 val_5 +0 val_0 5 val_5 +0 val_0 5 val_5 +0 val_0 5 val_5 +0 val_0 5 val_5 +0 val_0 8 val_8 +0 val_0 8 val_8 +0 val_0 8 val_8 +0 val_0 9 val_9 +0 val_0 9 val_9 +0 val_0 9 val_9 +2 val_2 0 val_0 +2 val_2 0 val_0 +2 val_2 0 val_0 +2 val_2 2 val_2 +2 val_2 4 val_4 +2 val_2 5 val_5 +2 val_2 5 val_5 +2 val_2 5 val_5 +2 val_2 8 val_8 +2 val_2 9 val_9 +4 val_4 0 val_0 +4 val_4 0 val_0 +4 val_4 0 val_0 +4 val_4 2 val_2 +4 val_4 4 val_4 +4 val_4 5 val_5 +4 val_4 5 val_5 +4 val_4 5 val_5 +4 val_4 8 val_8 +4 val_4 9 val_9 5 val_5 0 val_0 -5 val_5 4 val_4 -5 val_5 8 val_8 5 val_5 0 val_0 5 val_5 0 val_0 -5 val_5 5 val_5 +5 val_5 0 val_0 +5 val_5 0 val_0 +5 val_5 0 val_0 +5 val_5 0 val_0 +5 val_5 0 val_0 +5 val_5 0 val_0 5 val_5 2 val_2 +5 val_5 2 val_2 +5 val_5 2 val_2 +5 val_5 4 val_4 +5 val_5 4 val_4 +5 val_5 4 val_4 5 val_5 5 val_5 +5 val_5 5 val_5 +5 val_5 5 val_5 +5 val_5 5 val_5 +5 val_5 5 val_5 +5 val_5 5 val_5 +5 val_5 5 val_5 +5 val_5 5 val_5 +5 val_5 5 val_5 +5 val_5 8 val_8 +5 val_5 8 val_8 +5 val_5 8 val_8 5 val_5 9 val_9 -5 val_5 5 val_5 +5 val_5 9 val_9 +5 val_5 9 val_9 8 val_8 0 val_0 -8 val_8 4 val_4 -8 val_8 8 val_8 8 val_8 0 val_0 8 val_8 0 val_0 -8 val_8 5 val_5 8 val_8 2 val_2 +8 val_8 4 val_4 8 val_8 5 val_5 +8 val_8 5 val_5 +8 val_8 5 val_5 +8 val_8 8 val_8 8 val_8 9 val_9 -8 val_8 5 val_5 -5 val_5 0 val_0 -5 val_5 4 val_4 -5 val_5 8 val_8 -5 val_5 0 val_0 -5 val_5 0 val_0 -5 val_5 5 val_5 -5 val_5 2 val_2 -5 val_5 5 val_5 -5 val_5 9 val_9 -5 val_5 5 val_5 -4 val_4 0 val_0 -4 val_4 4 val_4 -4 val_4 8 val_8 -4 val_4 0 val_0 -4 val_4 0 val_0 -4 val_4 5 val_5 -4 val_4 2 val_2 -4 val_4 5 val_5 -4 val_4 9 val_9 -4 val_4 5 val_5 -2 val_2 0 val_0 -2 val_2 4 val_4 -2 val_2 8 val_8 -2 val_2 0 val_0 -2 val_2 0 val_0 -2 val_2 5 val_5 -2 val_2 2 val_2 -2 val_2 5 val_5 -2 val_2 9 val_9 -2 val_2 5 val_5 -0 val_0 0 val_0 -0 val_0 4 val_4 -0 val_0 8 val_8 -0 val_0 0 val_0 -0 val_0 0 val_0 -0 val_0 5 val_5 -0 val_0 2 val_2 -0 val_0 5 val_5 -0 val_0 9 val_9 -0 val_0 5 val_5 -5 val_5 0 val_0 -5 val_5 4 val_4 -5 val_5 8 val_8 -5 val_5 0 val_0 -5 val_5 0 val_0 -5 val_5 5 val_5 -5 val_5 2 val_2 -5 val_5 5 val_5 -5 val_5 9 val_9 -5 val_5 5 val_5 -0 val_0 0 val_0 -0 val_0 4 val_4 -0 val_0 8 val_8 -0 val_0 0 val_0 -0 val_0 0 val_0 -0 val_0 5 val_5 -0 val_0 2 val_2 -0 val_0 5 val_5 -0 val_0 9 val_9 -0 val_0 5 val_5 -0 val_0 0 val_0 -0 val_0 4 val_4 -0 val_0 8 val_8 -0 val_0 0 val_0 -0 val_0 0 val_0 -0 val_0 5 val_5 -0 val_0 2 val_2 -0 val_0 5 val_5 -0 val_0 9 val_9 -0 val_0 5 val_5 +9 val_9 0 val_0 +9 val_9 0 val_0 +9 val_9 0 val_0 +9 val_9 2 val_2 +9 val_9 4 val_4 +9 val_9 5 val_5 +9 val_9 5 val_5 +9 val_9 5 val_5 +9 val_9 8 val_8 +9 val_9 9 val_9 Index: ql/src/test/queries/clientpositive/join0.q =================================================================== --- ql/src/test/queries/clientpositive/join0.q (revision 725564) +++ ql/src/test/queries/clientpositive/join0.q (working copy) @@ -1,11 +1,15 @@ EXPLAIN -SELECT * FROM +SELECT src1.key as k1, src1.value as v1, + src2.key as k2, src2.value as v2 FROM (SELECT * FROM src WHERE src.key < 10) src1 JOIN - (SELECT * FROM src WHERE src.key < 10) src2; + (SELECT * FROM src WHERE src.key < 10) src2 + SORT BY k1, v1, k2, v2; -SELECT * FROM +SELECT src1.key as k1, src1.value as v1, + src2.key as k2, src2.value as v2 FROM (SELECT * FROM src WHERE src.key < 10) src1 JOIN - (SELECT * FROM src WHERE src.key < 10) src2; + (SELECT * FROM src WHERE src.key < 10) src2 + SORT BY k1, v1, k2, v2;