hive-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jcama...@apache.org
Subject [01/22] hive git commit: HIVE-16602: Implement shared scans with Tez (Jesus Camacho Rodriguez, reviewed by Ashutosh Chauhan)
Date Sat, 13 May 2017 07:09:35 GMT
Repository: hive
Updated Branches:
  refs/heads/master f2fa83cd1 -> 59f657729


http://git-wip-us.apache.org/repos/asf/hive/blob/59f65772/ql/src/test/results/clientpositive/perf/query92.q.out
----------------------------------------------------------------------
diff --git a/ql/src/test/results/clientpositive/perf/query92.q.out b/ql/src/test/results/clientpositive/perf/query92.q.out
index a53c8e7..d3abc23 100644
--- a/ql/src/test/results/clientpositive/perf/query92.q.out
+++ b/ql/src/test/results/clientpositive/perf/query92.q.out
@@ -7,10 +7,10 @@ Plan optimized by CBO.
 Vertex dependency in root stage
 Reducer 2 <- Map 1 (SIMPLE_EDGE), Map 6 (SIMPLE_EDGE)
 Reducer 3 <- Reducer 2 (SIMPLE_EDGE)
-Reducer 4 <- Reducer 3 (SIMPLE_EDGE), Reducer 9 (SIMPLE_EDGE)
+Reducer 4 <- Reducer 3 (SIMPLE_EDGE), Reducer 8 (SIMPLE_EDGE)
 Reducer 5 <- Reducer 4 (CUSTOM_SIMPLE_EDGE)
-Reducer 8 <- Map 10 (SIMPLE_EDGE), Map 7 (SIMPLE_EDGE)
-Reducer 9 <- Reducer 8 (SIMPLE_EDGE)
+Reducer 7 <- Map 6 (SIMPLE_EDGE), Map 9 (SIMPLE_EDGE)
+Reducer 8 <- Reducer 7 (SIMPLE_EDGE)
 
 Stage-0
   Fetch Operator
@@ -40,15 +40,6 @@ Stage-0
                           Output:["_col0","_col1"],keys:_col2, _col1
                           Merge Join Operator [MERGEJOIN_46] (rows=633595212 width=88)
                             Conds:RS_6._col0=RS_7._col0(Inner),Output:["_col1","_col2"]
-                          <-Map 1 [SIMPLE_EDGE]
-                            SHUFFLE [RS_6]
-                              PartitionCols:_col0
-                              Select Operator [SEL_2] (rows=575995635 width=88)
-                                Output:["_col0","_col1","_col2"]
-                                Filter Operator [FIL_42] (rows=575995635 width=88)
-                                  predicate:ss_sold_date_sk is not null
-                                  TableScan [TS_0] (rows=575995635 width=88)
-                                    default@store_sales,ss,Tbl:COMPLETE,Col:NONE,Output:["ss_sold_date_sk","ss_item_sk","ss_customer_sk"]
                           <-Map 6 [SIMPLE_EDGE]
                             SHUFFLE [RS_7]
                               PartitionCols:_col0
@@ -58,28 +49,36 @@ Stage-0
                                   predicate:((d_month_seq >= 1206) and (d_month_seq <= 1217) and d_date_sk is not null)
                                   TableScan [TS_3] (rows=73049 width=1119)
                                     default@date_dim,d1,Tbl:COMPLETE,Col:NONE,Output:["d_date_sk","d_month_seq"]
-                <-Reducer 9 [SIMPLE_EDGE]
+                          <-Map 1 [SIMPLE_EDGE]
+                            SHUFFLE [RS_6]
+                              PartitionCols:_col0
+                              Select Operator [SEL_2] (rows=575995635 width=88)
+                                Output:["_col0","_col1","_col2"]
+                                Filter Operator [FIL_42] (rows=575995635 width=88)
+                                  predicate:ss_sold_date_sk is not null
+                                  TableScan [TS_0] (rows=575995635 width=88)
+                                    default@store_sales,ss,Tbl:COMPLETE,Col:NONE,Output:["ss_sold_date_sk","ss_item_sk","ss_customer_sk"]
+                <-Reducer 8 [SIMPLE_EDGE]
                   SHUFFLE [RS_29]
                     PartitionCols:_col0, _col1
                     Group By Operator [GBY_26] (rows=158394413 width=135)
                       Output:["_col0","_col1"],keys:KEY._col0, KEY._col1
-                    <-Reducer 8 [SIMPLE_EDGE]
+                    <-Reducer 7 [SIMPLE_EDGE]
                       SHUFFLE [RS_25]
                         PartitionCols:_col0, _col1
                         Group By Operator [GBY_24] (rows=316788826 width=135)
                           Output:["_col0","_col1"],keys:_col1, _col2
                           Merge Join Operator [MERGEJOIN_47] (rows=316788826 width=135)
                             Conds:RS_20._col0=RS_21._col0(Inner),Output:["_col1","_col2"]
-                          <-Map 10 [SIMPLE_EDGE]
+                          <-Map 6 [SIMPLE_EDGE]
                             SHUFFLE [RS_21]
                               PartitionCols:_col0
                               Select Operator [SEL_19] (rows=8116 width=1119)
                                 Output:["_col0"]
                                 Filter Operator [FIL_45] (rows=8116 width=1119)
                                   predicate:((d_month_seq >= 1206) and (d_month_seq <= 1217) and d_date_sk is not null)
-                                  TableScan [TS_17] (rows=73049 width=1119)
-                                    default@date_dim,d2,Tbl:COMPLETE,Col:NONE,Output:["d_date_sk","d_month_seq"]
-                          <-Map 7 [SIMPLE_EDGE]
+                                   Please refer to the previous TableScan [TS_3]
+                          <-Map 9 [SIMPLE_EDGE]
                             SHUFFLE [RS_20]
                               PartitionCols:_col0
                               Select Operator [SEL_16] (rows=287989836 width=135)

http://git-wip-us.apache.org/repos/asf/hive/blob/59f65772/ql/src/test/results/clientpositive/perf/query95.q.out
----------------------------------------------------------------------
diff --git a/ql/src/test/results/clientpositive/perf/query95.q.out b/ql/src/test/results/clientpositive/perf/query95.q.out
index 9b0d1b2..fa94d08 100644
--- a/ql/src/test/results/clientpositive/perf/query95.q.out
+++ b/ql/src/test/results/clientpositive/perf/query95.q.out
@@ -5,14 +5,14 @@ POSTHOOK: type: QUERY
 Plan optimized by CBO.
 
 Vertex dependency in root stage
-Reducer 11 <- Map 10 (SIMPLE_EDGE), Map 13 (SIMPLE_EDGE)
-Reducer 12 <- Map 14 (SIMPLE_EDGE), Reducer 11 (SIMPLE_EDGE)
-Reducer 2 <- Map 1 (SIMPLE_EDGE), Reducer 12 (SIMPLE_EDGE), Reducer 8 (SIMPLE_EDGE)
-Reducer 3 <- Map 15 (SIMPLE_EDGE), Reducer 2 (SIMPLE_EDGE)
-Reducer 4 <- Map 16 (SIMPLE_EDGE), Reducer 3 (SIMPLE_EDGE)
-Reducer 5 <- Map 17 (SIMPLE_EDGE), Reducer 4 (SIMPLE_EDGE)
+Reducer 10 <- Map 12 (SIMPLE_EDGE), Reducer 9 (SIMPLE_EDGE)
+Reducer 2 <- Map 1 (SIMPLE_EDGE), Reducer 10 (SIMPLE_EDGE), Reducer 8 (SIMPLE_EDGE)
+Reducer 3 <- Map 13 (SIMPLE_EDGE), Reducer 2 (SIMPLE_EDGE)
+Reducer 4 <- Map 14 (SIMPLE_EDGE), Reducer 3 (SIMPLE_EDGE)
+Reducer 5 <- Map 15 (SIMPLE_EDGE), Reducer 4 (SIMPLE_EDGE)
 Reducer 6 <- Reducer 5 (SIMPLE_EDGE)
-Reducer 8 <- Map 7 (SIMPLE_EDGE), Map 9 (SIMPLE_EDGE)
+Reducer 8 <- Map 11 (SIMPLE_EDGE), Map 7 (SIMPLE_EDGE)
+Reducer 9 <- Map 11 (SIMPLE_EDGE), Map 7 (SIMPLE_EDGE)
 
 Stage-0
   Fetch Operator
@@ -28,7 +28,7 @@ Stage-0
               Output:["_col0","_col1","_col2","_col3"],aggregations:["count(DISTINCT _col3)","sum(_col4)","sum(_col5)"],keys:_col3
               Merge Join Operator [MERGEJOIN_122] (rows=510219083 width=135)
                 Conds:RS_55._col2=RS_56._col0(Inner),Output:["_col3","_col4","_col5"]
-              <-Map 17 [SIMPLE_EDGE]
+              <-Map 15 [SIMPLE_EDGE]
                 SHUFFLE [RS_56]
                   PartitionCols:_col0
                   Select Operator [SEL_40] (rows=42 width=1850)
@@ -42,7 +42,7 @@ Stage-0
                   PartitionCols:_col2
                   Merge Join Operator [MERGEJOIN_121] (rows=463835520 width=135)
                     Conds:RS_52._col1=RS_53._col0(Inner),Output:["_col2","_col3","_col4","_col5"]
-                  <-Map 16 [SIMPLE_EDGE]
+                  <-Map 14 [SIMPLE_EDGE]
                     SHUFFLE [RS_53]
                       PartitionCols:_col0
                       Select Operator [SEL_37] (rows=20000000 width=1014)
@@ -56,7 +56,7 @@ Stage-0
                       PartitionCols:_col1
                       Merge Join Operator [MERGEJOIN_120] (rows=421668646 width=135)
                         Conds:RS_49._col0=RS_50._col0(Inner),Output:["_col1","_col2","_col3","_col4","_col5"]
-                      <-Map 15 [SIMPLE_EDGE]
+                      <-Map 13 [SIMPLE_EDGE]
                         SHUFFLE [RS_50]
                           PartitionCols:_col0
                           Select Operator [SEL_34] (rows=8116 width=1119)
@@ -79,7 +79,7 @@ Stage-0
                                   predicate:(ws_ship_addr_sk is not null and ws_web_site_sk is not null and ws_ship_date_sk is not null and ws_order_number is not null)
                                   TableScan [TS_0] (rows=144002668 width=135)
                                     default@web_sales,ws1,Tbl:COMPLETE,Col:NONE,Output:["ws_ship_date_sk","ws_ship_addr_sk","ws_web_site_sk","ws_order_number","ws_ext_ship_cost","ws_net_profit"]
-                          <-Reducer 12 [SIMPLE_EDGE]
+                          <-Reducer 10 [SIMPLE_EDGE]
                             SHUFFLE [RS_47]
                               PartitionCols:_col0
                               Group By Operator [GBY_44] (rows=174243235 width=135)
@@ -88,7 +88,7 @@ Stage-0
                                   Output:["_col0"]
                                   Merge Join Operator [MERGEJOIN_118] (rows=174243235 width=135)
                                     Conds:RS_28._col0=RS_29._col0(Inner),Output:["_col1"]
-                                  <-Map 14 [SIMPLE_EDGE]
+                                  <-Map 12 [SIMPLE_EDGE]
                                     SHUFFLE [RS_29]
                                       PartitionCols:_col0
                                       Select Operator [SEL_27] (rows=14398467 width=92)
@@ -97,7 +97,7 @@ Stage-0
                                           predicate:wr_order_number is not null
                                           TableScan [TS_25] (rows=14398467 width=92)
                                             default@web_returns,wr,Tbl:COMPLETE,Col:NONE,Output:["wr_order_number"]
-                                  <-Reducer 11 [SIMPLE_EDGE]
+                                  <-Reducer 9 [SIMPLE_EDGE]
                                     SHUFFLE [RS_28]
                                       PartitionCols:_col0
                                       Select Operator [SEL_24] (rows=158402938 width=135)
@@ -106,24 +106,24 @@ Stage-0
                                           predicate:(_col0 <> _col2)
                                           Merge Join Operator [MERGEJOIN_117] (rows=158402938 width=135)
                                             Conds:RS_20._col1=RS_21._col1(Inner),Output:["_col0","_col1","_col2"]
-                                          <-Map 10 [SIMPLE_EDGE]
-                                            SHUFFLE [RS_20]
-                                              PartitionCols:_col1
-                                              Select Operator [SEL_16] (rows=144002668 width=135)
-                                                Output:["_col0","_col1"]
-                                                Filter Operator [FIL_110] (rows=144002668 width=135)
-                                                  predicate:ws_order_number is not null
-                                                  TableScan [TS_14] (rows=144002668 width=135)
-                                                    default@web_sales,ws4,Tbl:COMPLETE,Col:NONE,Output:["ws_warehouse_sk","ws_order_number"]
-                                          <-Map 13 [SIMPLE_EDGE]
+                                          <-Map 11 [SIMPLE_EDGE]
                                             SHUFFLE [RS_21]
                                               PartitionCols:_col1
                                               Select Operator [SEL_19] (rows=144002668 width=135)
                                                 Output:["_col0","_col1"]
                                                 Filter Operator [FIL_111] (rows=144002668 width=135)
                                                   predicate:ws_order_number is not null
-                                                  TableScan [TS_17] (rows=144002668 width=135)
-                                                    default@web_sales,ws5,Tbl:COMPLETE,Col:NONE,Output:["ws_warehouse_sk","ws_order_number"]
+                                                  TableScan [TS_6] (rows=144002668 width=135)
+                                                    default@web_sales,ws3,Tbl:COMPLETE,Col:NONE,Output:["ws_warehouse_sk","ws_order_number"]
+                                          <-Map 7 [SIMPLE_EDGE]
+                                            SHUFFLE [RS_20]
+                                              PartitionCols:_col1
+                                              Select Operator [SEL_16] (rows=144002668 width=135)
+                                                Output:["_col0","_col1"]
+                                                Filter Operator [FIL_110] (rows=144002668 width=135)
+                                                  predicate:ws_order_number is not null
+                                                  TableScan [TS_3] (rows=144002668 width=135)
+                                                    default@web_sales,ws2,Tbl:COMPLETE,Col:NONE,Output:["ws_warehouse_sk","ws_order_number"]
                           <-Reducer 8 [SIMPLE_EDGE]
                             SHUFFLE [RS_46]
                               PartitionCols:_col0
@@ -135,6 +135,14 @@ Stage-0
                                     predicate:(_col0 <> _col2)
                                     Merge Join Operator [MERGEJOIN_116] (rows=158402938 width=135)
                                       Conds:RS_9._col1=RS_10._col1(Inner),Output:["_col0","_col1","_col2"]
+                                    <-Map 11 [SIMPLE_EDGE]
+                                      SHUFFLE [RS_10]
+                                        PartitionCols:_col1
+                                        Select Operator [SEL_8] (rows=144002668 width=135)
+                                          Output:["_col0","_col1"]
+                                          Filter Operator [FIL_109] (rows=144002668 width=135)
+                                            predicate:ws_order_number is not null
+                                             Please refer to the previous TableScan [TS_6]
                                     <-Map 7 [SIMPLE_EDGE]
                                       SHUFFLE [RS_9]
                                         PartitionCols:_col1
@@ -142,15 +150,5 @@ Stage-0
                                           Output:["_col0","_col1"]
                                           Filter Operator [FIL_108] (rows=144002668 width=135)
                                             predicate:ws_order_number is not null
-                                            TableScan [TS_3] (rows=144002668 width=135)
-                                              default@web_sales,ws2,Tbl:COMPLETE,Col:NONE,Output:["ws_warehouse_sk","ws_order_number"]
-                                    <-Map 9 [SIMPLE_EDGE]
-                                      SHUFFLE [RS_10]
-                                        PartitionCols:_col1
-                                        Select Operator [SEL_8] (rows=144002668 width=135)
-                                          Output:["_col0","_col1"]
-                                          Filter Operator [FIL_109] (rows=144002668 width=135)
-                                            predicate:ws_order_number is not null
-                                            TableScan [TS_6] (rows=144002668 width=135)
-                                              default@web_sales,ws3,Tbl:COMPLETE,Col:NONE,Output:["ws_warehouse_sk","ws_order_number"]
+                                             Please refer to the previous TableScan [TS_3]
 

http://git-wip-us.apache.org/repos/asf/hive/blob/59f65772/ql/src/test/results/clientpositive/perf/query97.q.out
----------------------------------------------------------------------
diff --git a/ql/src/test/results/clientpositive/perf/query97.q.out b/ql/src/test/results/clientpositive/perf/query97.q.out
index 54152e9..ef9a791 100644
--- a/ql/src/test/results/clientpositive/perf/query97.q.out
+++ b/ql/src/test/results/clientpositive/perf/query97.q.out
@@ -7,10 +7,10 @@ Plan optimized by CBO.
 Vertex dependency in root stage
 Reducer 2 <- Map 1 (SIMPLE_EDGE), Map 6 (SIMPLE_EDGE)
 Reducer 3 <- Reducer 2 (SIMPLE_EDGE)
-Reducer 4 <- Reducer 3 (SIMPLE_EDGE), Reducer 9 (SIMPLE_EDGE)
+Reducer 4 <- Reducer 3 (SIMPLE_EDGE), Reducer 8 (SIMPLE_EDGE)
 Reducer 5 <- Reducer 4 (CUSTOM_SIMPLE_EDGE)
-Reducer 8 <- Map 10 (SIMPLE_EDGE), Map 7 (SIMPLE_EDGE)
-Reducer 9 <- Reducer 8 (SIMPLE_EDGE)
+Reducer 7 <- Map 6 (SIMPLE_EDGE), Map 9 (SIMPLE_EDGE)
+Reducer 8 <- Reducer 7 (SIMPLE_EDGE)
 
 Stage-0
   Fetch Operator
@@ -42,15 +42,6 @@ Stage-0
                             Output:["_col0","_col1"],keys:_col2, _col1
                             Merge Join Operator [MERGEJOIN_47] (rows=633595212 width=88)
                               Conds:RS_6._col0=RS_7._col0(Inner),Output:["_col1","_col2"]
-                            <-Map 1 [SIMPLE_EDGE]
-                              SHUFFLE [RS_6]
-                                PartitionCols:_col0
-                                Select Operator [SEL_2] (rows=575995635 width=88)
-                                  Output:["_col0","_col1","_col2"]
-                                  Filter Operator [FIL_43] (rows=575995635 width=88)
-                                    predicate:ss_sold_date_sk is not null
-                                    TableScan [TS_0] (rows=575995635 width=88)
-                                      default@store_sales,store_sales,Tbl:COMPLETE,Col:NONE,Output:["ss_sold_date_sk","ss_item_sk","ss_customer_sk"]
                             <-Map 6 [SIMPLE_EDGE]
                               SHUFFLE [RS_7]
                                 PartitionCols:_col0
@@ -60,28 +51,36 @@ Stage-0
                                     predicate:(d_month_seq BETWEEN 1193 AND 1204 and d_date_sk is not null)
                                     TableScan [TS_3] (rows=73049 width=1119)
                                       default@date_dim,date_dim,Tbl:COMPLETE,Col:NONE,Output:["d_date_sk","d_month_seq"]
-                  <-Reducer 9 [SIMPLE_EDGE]
+                            <-Map 1 [SIMPLE_EDGE]
+                              SHUFFLE [RS_6]
+                                PartitionCols:_col0
+                                Select Operator [SEL_2] (rows=575995635 width=88)
+                                  Output:["_col0","_col1","_col2"]
+                                  Filter Operator [FIL_43] (rows=575995635 width=88)
+                                    predicate:ss_sold_date_sk is not null
+                                    TableScan [TS_0] (rows=575995635 width=88)
+                                      default@store_sales,store_sales,Tbl:COMPLETE,Col:NONE,Output:["ss_sold_date_sk","ss_item_sk","ss_customer_sk"]
+                  <-Reducer 8 [SIMPLE_EDGE]
                     SHUFFLE [RS_29]
                       PartitionCols:_col0, _col1
                       Group By Operator [GBY_26] (rows=158394413 width=135)
                         Output:["_col0","_col1"],keys:KEY._col0, KEY._col1
-                      <-Reducer 8 [SIMPLE_EDGE]
+                      <-Reducer 7 [SIMPLE_EDGE]
                         SHUFFLE [RS_25]
                           PartitionCols:_col0, _col1
                           Group By Operator [GBY_24] (rows=316788826 width=135)
                             Output:["_col0","_col1"],keys:_col1, _col2
                             Merge Join Operator [MERGEJOIN_48] (rows=316788826 width=135)
                               Conds:RS_20._col0=RS_21._col0(Inner),Output:["_col1","_col2"]
-                            <-Map 10 [SIMPLE_EDGE]
+                            <-Map 6 [SIMPLE_EDGE]
                               SHUFFLE [RS_21]
                                 PartitionCols:_col0
                                 Select Operator [SEL_19] (rows=8116 width=1119)
                                   Output:["_col0"]
                                   Filter Operator [FIL_46] (rows=8116 width=1119)
                                     predicate:(d_month_seq BETWEEN 1193 AND 1204 and d_date_sk is not null)
-                                    TableScan [TS_17] (rows=73049 width=1119)
-                                      default@date_dim,date_dim,Tbl:COMPLETE,Col:NONE,Output:["d_date_sk","d_month_seq"]
-                            <-Map 7 [SIMPLE_EDGE]
+                                     Please refer to the previous TableScan [TS_3]
+                            <-Map 9 [SIMPLE_EDGE]
                               SHUFFLE [RS_20]
                                 PartitionCols:_col0
                                 Select Operator [SEL_16] (rows=287989836 width=135)

http://git-wip-us.apache.org/repos/asf/hive/blob/59f65772/ql/src/test/results/clientpositive/tez/explainanalyze_2.q.out
----------------------------------------------------------------------
diff --git a/ql/src/test/results/clientpositive/tez/explainanalyze_2.q.out b/ql/src/test/results/clientpositive/tez/explainanalyze_2.q.out
index ea572cd..f6844c4 100644
--- a/ql/src/test/results/clientpositive/tez/explainanalyze_2.q.out
+++ b/ql/src/test/results/clientpositive/tez/explainanalyze_2.q.out
@@ -42,15 +42,15 @@ Plan optimized by CBO.
 
 Vertex dependency in root stage
 Map 1 <- Union 2 (CONTAINS)
-Map 11 <- Union 12 (CONTAINS)
-Map 16 <- Union 12 (CONTAINS)
+Map 13 <- Union 14 (CONTAINS)
+Map 16 <- Union 14 (CONTAINS)
 Map 8 <- Union 2 (CONTAINS)
-Reducer 13 <- Union 12 (SIMPLE_EDGE)
-Reducer 14 <- Map 17 (SIMPLE_EDGE), Reducer 13 (SIMPLE_EDGE)
-Reducer 15 <- Map 18 (SIMPLE_EDGE), Reducer 14 (SIMPLE_EDGE), Union 6 (CONTAINS)
+Reducer 10 <- Map 9 (SIMPLE_EDGE), Reducer 15 (SIMPLE_EDGE)
+Reducer 11 <- Map 17 (SIMPLE_EDGE), Reducer 10 (SIMPLE_EDGE), Union 6 (CONTAINS)
+Reducer 15 <- Union 14 (SIMPLE_EDGE)
 Reducer 3 <- Union 2 (SIMPLE_EDGE)
 Reducer 4 <- Map 9 (SIMPLE_EDGE), Reducer 3 (SIMPLE_EDGE)
-Reducer 5 <- Map 10 (SIMPLE_EDGE), Reducer 4 (SIMPLE_EDGE), Union 6 (CONTAINS)
+Reducer 5 <- Map 12 (SIMPLE_EDGE), Reducer 4 (SIMPLE_EDGE), Union 6 (CONTAINS)
 Reducer 7 <- Union 6 (SIMPLE_EDGE)
 
 Stage-0
@@ -62,14 +62,14 @@ Stage-0
         Group By Operator [GBY_54] (rows=28/15 width=177)
           Output:["_col0","_col1"],keys:KEY._col0, KEY._col1
         <-Union 6 [SIMPLE_EDGE]
-          <-Reducer 15 [CONTAINS]
+          <-Reducer 11 [CONTAINS]
             Reduce Output Operator [RS_53]
               PartitionCols:_col0, _col1
               Select Operator [SEL_49] (rows=148/61 width=177)
                 Output:["_col0","_col1"]
                 Merge Join Operator [MERGEJOIN_82] (rows=148/61 width=177)
                   Conds:RS_46._col2=RS_47._col0(Inner),Output:["_col1","_col2"]
-                <-Map 18 [SIMPLE_EDGE]
+                <-Map 17 [SIMPLE_EDGE]
                   SHUFFLE [RS_47]
                     PartitionCols:_col0
                     Select Operator [SEL_42] (rows=500/500 width=87)
@@ -78,29 +78,29 @@ Stage-0
                         predicate:key is not null
                         TableScan [TS_40] (rows=500/500 width=87)
                           default@src,y,Tbl:COMPLETE,Col:COMPLETE,Output:["key"]
-                <-Reducer 14 [SIMPLE_EDGE]
+                <-Reducer 10 [SIMPLE_EDGE]
                   SHUFFLE [RS_46]
                     PartitionCols:_col2
                     Merge Join Operator [MERGEJOIN_81] (rows=61/52 width=177)
                       Conds:RS_43._col1=RS_44._col1(Inner),Output:["_col1","_col2"]
-                    <-Map 17 [SIMPLE_EDGE]
+                    <-Map 9 [SIMPLE_EDGE]
                       SHUFFLE [RS_44]
                         PartitionCols:_col1
                         Select Operator [SEL_39] (rows=25/25 width=175)
                           Output:["_col0","_col1"]
                           Filter Operator [FIL_77] (rows=25/25 width=175)
                             predicate:(key is not null and value is not null)
-                            TableScan [TS_37] (rows=25/25 width=175)
+                            TableScan [TS_12] (rows=25/25 width=175)
                               default@src1,x,Tbl:COMPLETE,Col:COMPLETE,Output:["key","value"]
-                    <-Reducer 13 [SIMPLE_EDGE]
+                    <-Reducer 15 [SIMPLE_EDGE]
                       SHUFFLE [RS_43]
                         PartitionCols:_col1
                         Select Operator [SEL_36] (rows=525/319 width=178)
                           Output:["_col1"]
                           Group By Operator [GBY_35] (rows=525/319 width=178)
                             Output:["_col0","_col1"],keys:KEY._col0, KEY._col1
-                          <-Union 12 [SIMPLE_EDGE]
-                            <-Map 11 [CONTAINS]
+                          <-Union 14 [SIMPLE_EDGE]
+                            <-Map 13 [CONTAINS]
                               Reduce Output Operator [RS_34]
                                 PartitionCols:_col1, _col0
                                 Select Operator [SEL_27] (rows=25/25 width=175)
@@ -125,7 +125,7 @@ Stage-0
                 Output:["_col0","_col1"]
                 Merge Join Operator [MERGEJOIN_80] (rows=148/61 width=177)
                   Conds:RS_21._col2=RS_22._col0(Inner),Output:["_col1","_col2"]
-                <-Map 10 [SIMPLE_EDGE]
+                <-Map 12 [SIMPLE_EDGE]
                   SHUFFLE [RS_22]
                     PartitionCols:_col0
                     Select Operator [SEL_17] (rows=500/500 width=87)
@@ -146,8 +146,7 @@ Stage-0
                           Output:["_col0","_col1"]
                           Filter Operator [FIL_73] (rows=25/25 width=175)
                             predicate:(key is not null and value is not null)
-                            TableScan [TS_12] (rows=25/25 width=175)
-                              default@src1,x,Tbl:COMPLETE,Col:COMPLETE,Output:["key","value"]
+                             Please refer to the previous TableScan [TS_12]
                     <-Reducer 3 [SIMPLE_EDGE]
                       SHUFFLE [RS_18]
                         PartitionCols:_col1
@@ -236,25 +235,25 @@ Plan optimized by CBO.
 Vertex dependency in root stage
 Map 1 <- Union 2 (CONTAINS)
 Map 10 <- Union 2 (CONTAINS)
-Map 13 <- Union 14 (CONTAINS)
-Map 20 <- Union 14 (CONTAINS)
-Map 21 <- Union 16 (CONTAINS)
-Map 24 <- Union 25 (CONTAINS)
-Map 33 <- Union 25 (CONTAINS)
-Map 34 <- Union 27 (CONTAINS)
-Map 35 <- Union 29 (CONTAINS)
-Reducer 15 <- Union 14 (SIMPLE_EDGE), Union 16 (CONTAINS)
-Reducer 17 <- Union 16 (SIMPLE_EDGE)
-Reducer 18 <- Map 22 (SIMPLE_EDGE), Reducer 17 (SIMPLE_EDGE)
-Reducer 19 <- Map 23 (SIMPLE_EDGE), Reducer 18 (SIMPLE_EDGE), Union 6 (CONTAINS)
-Reducer 26 <- Union 25 (SIMPLE_EDGE), Union 27 (CONTAINS)
-Reducer 28 <- Union 27 (SIMPLE_EDGE), Union 29 (CONTAINS)
+Map 17 <- Union 18 (CONTAINS)
+Map 22 <- Union 18 (CONTAINS)
+Map 23 <- Union 20 (CONTAINS)
+Map 25 <- Union 26 (CONTAINS)
+Map 32 <- Union 26 (CONTAINS)
+Map 33 <- Union 28 (CONTAINS)
+Map 34 <- Union 30 (CONTAINS)
+Reducer 12 <- Map 11 (SIMPLE_EDGE), Reducer 21 (SIMPLE_EDGE)
+Reducer 13 <- Map 24 (SIMPLE_EDGE), Reducer 12 (SIMPLE_EDGE), Union 6 (CONTAINS)
+Reducer 14 <- Map 11 (SIMPLE_EDGE), Reducer 31 (SIMPLE_EDGE)
+Reducer 15 <- Map 16 (SIMPLE_EDGE), Reducer 14 (SIMPLE_EDGE), Union 8 (CONTAINS)
+Reducer 19 <- Union 18 (SIMPLE_EDGE), Union 20 (CONTAINS)
+Reducer 21 <- Union 20 (SIMPLE_EDGE)
+Reducer 27 <- Union 26 (SIMPLE_EDGE), Union 28 (CONTAINS)
+Reducer 29 <- Union 28 (SIMPLE_EDGE), Union 30 (CONTAINS)
 Reducer 3 <- Union 2 (SIMPLE_EDGE)
-Reducer 30 <- Union 29 (SIMPLE_EDGE)
-Reducer 31 <- Map 36 (SIMPLE_EDGE), Reducer 30 (SIMPLE_EDGE)
-Reducer 32 <- Map 37 (SIMPLE_EDGE), Reducer 31 (SIMPLE_EDGE), Union 8 (CONTAINS)
+Reducer 31 <- Union 30 (SIMPLE_EDGE)
 Reducer 4 <- Map 11 (SIMPLE_EDGE), Reducer 3 (SIMPLE_EDGE)
-Reducer 5 <- Map 12 (SIMPLE_EDGE), Reducer 4 (SIMPLE_EDGE), Union 6 (CONTAINS)
+Reducer 5 <- Map 16 (SIMPLE_EDGE), Reducer 4 (SIMPLE_EDGE), Union 6 (CONTAINS)
 Reducer 7 <- Union 6 (SIMPLE_EDGE), Union 8 (CONTAINS)
 Reducer 9 <- Union 8 (SIMPLE_EDGE)
 
@@ -267,45 +266,45 @@ Stage-0
         Group By Operator [GBY_112] (rows=872/15 width=177)
           Output:["_col0","_col1"],keys:KEY._col0, KEY._col1
         <-Union 8 [SIMPLE_EDGE]
-          <-Reducer 32 [CONTAINS]
+          <-Reducer 15 [CONTAINS]
             Reduce Output Operator [RS_111]
               PartitionCols:_col0, _col1
               Select Operator [SEL_107] (rows=434/61 width=177)
                 Output:["_col0","_col1"]
                 Merge Join Operator [MERGEJOIN_162] (rows=434/61 width=177)
                   Conds:RS_104._col2=RS_105._col0(Inner),Output:["_col2","_col5"]
-                <-Map 37 [SIMPLE_EDGE]
+                <-Map 16 [SIMPLE_EDGE]
                   SHUFFLE [RS_105]
                     PartitionCols:_col0
                     Select Operator [SEL_100] (rows=500/500 width=178)
                       Output:["_col0","_col1"]
                       Filter Operator [FIL_156] (rows=500/500 width=178)
                         predicate:key is not null
-                        TableScan [TS_98] (rows=500/500 width=178)
+                        TableScan [TS_15] (rows=500/500 width=178)
                           default@src,y,Tbl:COMPLETE,Col:COMPLETE,Output:["key","value"]
-                <-Reducer 31 [SIMPLE_EDGE]
+                <-Reducer 14 [SIMPLE_EDGE]
                   SHUFFLE [RS_104]
                     PartitionCols:_col2
                     Merge Join Operator [MERGEJOIN_161] (rows=178/52 width=86)
                       Conds:RS_101._col1=RS_102._col1(Inner),Output:["_col2"]
-                    <-Map 36 [SIMPLE_EDGE]
+                    <-Map 11 [SIMPLE_EDGE]
                       SHUFFLE [RS_102]
                         PartitionCols:_col1
                         Select Operator [SEL_97] (rows=25/25 width=175)
                           Output:["_col0","_col1"]
                           Filter Operator [FIL_155] (rows=25/25 width=175)
                             predicate:(key is not null and value is not null)
-                            TableScan [TS_95] (rows=25/25 width=175)
+                            TableScan [TS_12] (rows=25/25 width=175)
                               default@src1,x,Tbl:COMPLETE,Col:COMPLETE,Output:["key","value"]
-                    <-Reducer 30 [SIMPLE_EDGE]
+                    <-Reducer 31 [SIMPLE_EDGE]
                       SHUFFLE [RS_101]
                         PartitionCols:_col1
                         Select Operator [SEL_94] (rows=1525/319 width=178)
                           Output:["_col1"]
                           Group By Operator [GBY_93] (rows=1525/319 width=178)
                             Output:["_col0","_col1"],keys:KEY._col0, KEY._col1
-                          <-Union 29 [SIMPLE_EDGE]
-                            <-Map 35 [CONTAINS]
+                          <-Union 30 [SIMPLE_EDGE]
+                            <-Map 34 [CONTAINS]
                               Reduce Output Operator [RS_92]
                                 PartitionCols:_col1, _col0
                                 Select Operator [SEL_88] (rows=500/500 width=178)
@@ -314,15 +313,15 @@ Stage-0
                                     predicate:value is not null
                                     TableScan [TS_86] (rows=500/500 width=178)
                                       Output:["key","value"]
-                            <-Reducer 28 [CONTAINS]
+                            <-Reducer 29 [CONTAINS]
                               Reduce Output Operator [RS_92]
                                 PartitionCols:_col1, _col0
                                 Select Operator [SEL_85] (rows=1025/319 width=178)
                                   Output:["_col0","_col1"]
                                   Group By Operator [GBY_84] (rows=1025/319 width=178)
                                     Output:["_col0","_col1"],keys:KEY._col0, KEY._col1
-                                  <-Union 27 [SIMPLE_EDGE]
-                                    <-Map 34 [CONTAINS]
+                                  <-Union 28 [SIMPLE_EDGE]
+                                    <-Map 33 [CONTAINS]
                                       Reduce Output Operator [RS_83]
                                         PartitionCols:_col1, _col0
                                         Select Operator [SEL_79] (rows=500/500 width=178)
@@ -331,15 +330,15 @@ Stage-0
                                             predicate:value is not null
                                             TableScan [TS_77] (rows=500/500 width=178)
                                               Output:["key","value"]
-                                    <-Reducer 26 [CONTAINS]
+                                    <-Reducer 27 [CONTAINS]
                                       Reduce Output Operator [RS_83]
                                         PartitionCols:_col1, _col0
                                         Select Operator [SEL_76] (rows=525/319 width=178)
                                           Output:["_col0","_col1"]
                                           Group By Operator [GBY_75] (rows=525/319 width=178)
                                             Output:["_col0","_col1"],keys:KEY._col0, KEY._col1
-                                          <-Union 25 [SIMPLE_EDGE]
-                                            <-Map 24 [CONTAINS]
+                                          <-Union 26 [SIMPLE_EDGE]
+                                            <-Map 25 [CONTAINS]
                                               Reduce Output Operator [RS_74]
                                                 PartitionCols:_col1, _col0
                                                 Select Operator [SEL_67] (rows=25/25 width=175)
@@ -348,7 +347,7 @@ Stage-0
                                                     predicate:value is not null
                                                     TableScan [TS_65] (rows=25/25 width=175)
                                                       Output:["key","value"]
-                                            <-Map 33 [CONTAINS]
+                                            <-Map 32 [CONTAINS]
                                               Reduce Output Operator [RS_74]
                                                 PartitionCols:_col1, _col0
                                                 Select Operator [SEL_70] (rows=500/500 width=178)
@@ -363,14 +362,14 @@ Stage-0
               Group By Operator [GBY_63] (rows=438/15 width=177)
                 Output:["_col0","_col1"],keys:KEY._col0, KEY._col1
               <-Union 6 [SIMPLE_EDGE]
-                <-Reducer 19 [CONTAINS]
+                <-Reducer 13 [CONTAINS]
                   Reduce Output Operator [RS_62]
                     PartitionCols:_col0, _col1
                     Select Operator [SEL_58] (rows=290/61 width=177)
                       Output:["_col0","_col1"]
                       Merge Join Operator [MERGEJOIN_160] (rows=290/61 width=177)
                         Conds:RS_55._col2=RS_56._col0(Inner),Output:["_col2","_col5"]
-                      <-Map 23 [SIMPLE_EDGE]
+                      <-Map 24 [SIMPLE_EDGE]
                         SHUFFLE [RS_56]
                           PartitionCols:_col0
                           Select Operator [SEL_51] (rows=500/500 width=178)
@@ -379,29 +378,28 @@ Stage-0
                               predicate:key is not null
                               TableScan [TS_49] (rows=500/500 width=178)
                                 default@src,y,Tbl:COMPLETE,Col:COMPLETE,Output:["key","value"]
-                      <-Reducer 18 [SIMPLE_EDGE]
+                      <-Reducer 12 [SIMPLE_EDGE]
                         SHUFFLE [RS_55]
                           PartitionCols:_col2
                           Merge Join Operator [MERGEJOIN_159] (rows=119/52 width=86)
                             Conds:RS_52._col1=RS_53._col1(Inner),Output:["_col2"]
-                          <-Map 22 [SIMPLE_EDGE]
+                          <-Map 11 [SIMPLE_EDGE]
                             SHUFFLE [RS_53]
                               PartitionCols:_col1
                               Select Operator [SEL_48] (rows=25/25 width=175)
                                 Output:["_col0","_col1"]
                                 Filter Operator [FIL_149] (rows=25/25 width=175)
                                   predicate:(key is not null and value is not null)
-                                  TableScan [TS_46] (rows=25/25 width=175)
-                                    default@src1,x,Tbl:COMPLETE,Col:COMPLETE,Output:["key","value"]
-                          <-Reducer 17 [SIMPLE_EDGE]
+                                   Please refer to the previous TableScan [TS_12]
+                          <-Reducer 21 [SIMPLE_EDGE]
                             SHUFFLE [RS_52]
                               PartitionCols:_col1
                               Select Operator [SEL_45] (rows=1025/319 width=178)
                                 Output:["_col1"]
                                 Group By Operator [GBY_44] (rows=1025/319 width=178)
                                   Output:["_col0","_col1"],keys:KEY._col0, KEY._col1
-                                <-Union 16 [SIMPLE_EDGE]
-                                  <-Map 21 [CONTAINS]
+                                <-Union 20 [SIMPLE_EDGE]
+                                  <-Map 23 [CONTAINS]
                                     Reduce Output Operator [RS_43]
                                       PartitionCols:_col1, _col0
                                       Select Operator [SEL_39] (rows=500/500 width=178)
@@ -410,15 +408,15 @@ Stage-0
                                           predicate:value is not null
                                           TableScan [TS_37] (rows=500/500 width=178)
                                             Output:["key","value"]
-                                  <-Reducer 15 [CONTAINS]
+                                  <-Reducer 19 [CONTAINS]
                                     Reduce Output Operator [RS_43]
                                       PartitionCols:_col1, _col0
                                       Select Operator [SEL_36] (rows=525/319 width=178)
                                         Output:["_col0","_col1"]
                                         Group By Operator [GBY_35] (rows=525/319 width=178)
                                           Output:["_col0","_col1"],keys:KEY._col0, KEY._col1
-                                        <-Union 14 [SIMPLE_EDGE]
-                                          <-Map 13 [CONTAINS]
+                                        <-Union 18 [SIMPLE_EDGE]
+                                          <-Map 17 [CONTAINS]
                                             Reduce Output Operator [RS_34]
                                               PartitionCols:_col1, _col0
                                               Select Operator [SEL_27] (rows=25/25 width=175)
@@ -427,7 +425,7 @@ Stage-0
                                                   predicate:value is not null
                                                   TableScan [TS_25] (rows=25/25 width=175)
                                                     Output:["key","value"]
-                                          <-Map 20 [CONTAINS]
+                                          <-Map 22 [CONTAINS]
                                             Reduce Output Operator [RS_34]
                                               PartitionCols:_col1, _col0
                                               Select Operator [SEL_30] (rows=500/500 width=178)
@@ -443,15 +441,14 @@ Stage-0
                       Output:["_col0","_col1"]
                       Merge Join Operator [MERGEJOIN_158] (rows=148/61 width=177)
                         Conds:RS_21._col2=RS_22._col0(Inner),Output:["_col2","_col5"]
-                      <-Map 12 [SIMPLE_EDGE]
+                      <-Map 16 [SIMPLE_EDGE]
                         SHUFFLE [RS_22]
                           PartitionCols:_col0
                           Select Operator [SEL_17] (rows=500/500 width=178)
                             Output:["_col0","_col1"]
                             Filter Operator [FIL_145] (rows=500/500 width=178)
                               predicate:key is not null
-                              TableScan [TS_15] (rows=500/500 width=178)
-                                default@src,y,Tbl:COMPLETE,Col:COMPLETE,Output:["key","value"]
+                               Please refer to the previous TableScan [TS_15]
                       <-Reducer 4 [SIMPLE_EDGE]
                         SHUFFLE [RS_21]
                           PartitionCols:_col2
@@ -464,8 +461,7 @@ Stage-0
                                 Output:["_col0","_col1"]
                                 Filter Operator [FIL_144] (rows=25/25 width=175)
                                   predicate:(key is not null and value is not null)
-                                  TableScan [TS_12] (rows=25/25 width=175)
-                                    default@src1,x,Tbl:COMPLETE,Col:COMPLETE,Output:["key","value"]
+                                   Please refer to the previous TableScan [TS_12]
                           <-Reducer 3 [SIMPLE_EDGE]
                             SHUFFLE [RS_18]
                               PartitionCols:_col1
@@ -1127,20 +1123,20 @@ Plan optimized by CBO.
 
 Vertex dependency in root stage
 Map 1 <- Union 2 (CONTAINS)
-Map 13 <- Union 10 (CONTAINS)
-Map 14 <- Union 10 (CONTAINS)
-Map 21 <- Union 22 (CONTAINS)
-Map 23 <- Union 22 (CONTAINS)
-Map 24 <- Union 22 (CONTAINS)
-Map 25 <- Union 22 (CONTAINS)
+Map 13 <- Union 14 (CONTAINS)
+Map 15 <- Union 14 (CONTAINS)
+Map 16 <- Union 14 (CONTAINS)
+Map 19 <- Union 20 (CONTAINS)
+Map 21 <- Union 20 (CONTAINS)
+Map 22 <- Union 20 (CONTAINS)
+Map 23 <- Union 20 (CONTAINS)
 Map 6 <- Union 2 (CONTAINS)
-Map 9 <- Union 10 (CONTAINS)
-Reducer 11 <- Map 15 (SIMPLE_EDGE), Union 10 (SIMPLE_EDGE)
-Reducer 12 <- Map 16 (SIMPLE_EDGE), Reducer 11 (SIMPLE_EDGE), Union 5 (CONTAINS)
-Reducer 18 <- Map 17 (SIMPLE_EDGE), Map 20 (SIMPLE_EDGE)
-Reducer 19 <- Reducer 18 (SIMPLE_EDGE), Union 22 (SIMPLE_EDGE), Union 5 (CONTAINS)
+Reducer 11 <- Map 10 (SIMPLE_EDGE), Union 14 (SIMPLE_EDGE)
+Reducer 12 <- Map 17 (SIMPLE_EDGE), Reducer 11 (SIMPLE_EDGE), Union 5 (CONTAINS)
 Reducer 3 <- Map 7 (SIMPLE_EDGE), Union 2 (SIMPLE_EDGE)
-Reducer 4 <- Map 8 (SIMPLE_EDGE), Reducer 3 (SIMPLE_EDGE), Union 5 (CONTAINS)
+Reducer 4 <- Map 10 (SIMPLE_EDGE), Reducer 3 (SIMPLE_EDGE), Union 5 (CONTAINS)
+Reducer 8 <- Map 18 (SIMPLE_EDGE), Map 7 (SIMPLE_EDGE)
+Reducer 9 <- Reducer 8 (SIMPLE_EDGE), Union 20 (SIMPLE_EDGE), Union 5 (CONTAINS)
 
 Stage-5
   Stats-Aggr Operator
@@ -1158,7 +1154,7 @@ Stage-5
                     Output:["_col0","_col1"]
                     Merge Join Operator [MERGEJOIN_126] (rows=5839/5421 width=178)
                       Conds:RS_42._col1=RS_43._col0(Inner),Output:["_col1","_col4"]
-                    <-Map 16 [SIMPLE_EDGE]
+                    <-Map 17 [SIMPLE_EDGE]
                       SHUFFLE [RS_43]
                         PartitionCols:_col0
                         Select Operator [SEL_38] (rows=500/500 width=178)
@@ -1171,27 +1167,36 @@ Stage-5
                       SHUFFLE [RS_42]
                         PartitionCols:_col1
                         Merge Join Operator [MERGEJOIN_125] (rows=2394/2097 width=87)
-                          Conds:Union 10._col0=RS_40._col1(Inner),Output:["_col1"]
-                        <-Map 15 [SIMPLE_EDGE]
+                          Conds:Union 14._col0=RS_40._col1(Inner),Output:["_col1"]
+                        <-Map 10 [SIMPLE_EDGE]
                           SHUFFLE [RS_40]
                             PartitionCols:_col1
                             Select Operator [SEL_35] (rows=500/500 width=178)
                               Output:["_col0","_col1"]
                               Filter Operator [FIL_115] (rows=500/500 width=178)
                                 predicate:(key is not null and value is not null)
-                                TableScan [TS_33] (rows=500/500 width=178)
-                                  default@src,x,Tbl:COMPLETE,Col:COMPLETE,Output:["key","value"]
-                        <-Union 10 [SIMPLE_EDGE]
+                                TableScan [TS_11] (rows=500/500 width=178)
+                                  default@src,y,Tbl:COMPLETE,Col:COMPLETE,Output:["key","value"]
+                        <-Union 14 [SIMPLE_EDGE]
                           <-Map 13 [CONTAINS]
                             Reduce Output Operator [RS_39]
                               PartitionCols:_col0
+                              Select Operator [SEL_23] (rows=25/25 width=89)
+                                Output:["_col0"]
+                                Filter Operator [FIL_112] (rows=25/25 width=89)
+                                  predicate:value is not null
+                                  TableScan [TS_21] (rows=25/25 width=89)
+                                    Output:["value"]
+                          <-Map 15 [CONTAINS]
+                            Reduce Output Operator [RS_39]
+                              PartitionCols:_col0
                               Select Operator [SEL_26] (rows=500/500 width=91)
                                 Output:["_col0"]
                                 Filter Operator [FIL_113] (rows=500/500 width=91)
                                   predicate:value is not null
                                   TableScan [TS_24] (rows=500/500 width=91)
                                     Output:["value"]
-                          <-Map 14 [CONTAINS]
+                          <-Map 16 [CONTAINS]
                             Reduce Output Operator [RS_39]
                               PartitionCols:_col0
                               Select Operator [SEL_31] (rows=500/500 width=91)
@@ -1200,43 +1205,87 @@ Stage-5
                                   predicate:value is not null
                                   TableScan [TS_29] (rows=500/500 width=91)
                                     Output:["value"]
-                          <-Map 9 [CONTAINS]
-                            Reduce Output Operator [RS_39]
+                File Output Operator [FS_81]
+                  table:{"name:":"default.b"}
+                   Please refer to the previous Select Operator [SEL_45]
+                File Output Operator [FS_83]
+                  table:{"name:":"default.c"}
+                   Please refer to the previous Select Operator [SEL_45]
+              <-Reducer 4 [CONTAINS]
+                File Output Operator [FS_79]
+                  table:{"name:":"default.a"}
+                  Select Operator [SEL_20] (rows=148/170 width=177)
+                    Output:["_col0","_col1"]
+                    Merge Join Operator [MERGEJOIN_124] (rows=148/170 width=177)
+                      Conds:RS_17._col1=RS_18._col0(Inner),Output:["_col1","_col4"]
+                    <-Map 10 [SIMPLE_EDGE]
+                      SHUFFLE [RS_18]
+                        PartitionCols:_col0
+                        Select Operator [SEL_13] (rows=500/500 width=178)
+                          Output:["_col0","_col1"]
+                          Filter Operator [FIL_111] (rows=500/500 width=178)
+                            predicate:key is not null
+                             Please refer to the previous TableScan [TS_11]
+                    <-Reducer 3 [SIMPLE_EDGE]
+                      SHUFFLE [RS_17]
+                        PartitionCols:_col1
+                        Merge Join Operator [MERGEJOIN_123] (rows=61/108 width=86)
+                          Conds:Union 2._col0=RS_15._col1(Inner),Output:["_col1"]
+                        <-Map 7 [SIMPLE_EDGE]
+                          SHUFFLE [RS_15]
+                            PartitionCols:_col1
+                            Select Operator [SEL_10] (rows=25/25 width=175)
+                              Output:["_col0","_col1"]
+                              Filter Operator [FIL_110] (rows=25/25 width=175)
+                                predicate:(key is not null and value is not null)
+                                TableScan [TS_8] (rows=25/25 width=175)
+                                  default@src1,x,Tbl:COMPLETE,Col:COMPLETE,Output:["key","value"]
+                        <-Union 2 [SIMPLE_EDGE]
+                          <-Map 1 [CONTAINS]
+                            Reduce Output Operator [RS_14]
                               PartitionCols:_col0
-                              Select Operator [SEL_23] (rows=25/25 width=89)
+                              Select Operator [SEL_2] (rows=25/25 width=89)
                                 Output:["_col0"]
-                                Filter Operator [FIL_112] (rows=25/25 width=89)
+                                Filter Operator [FIL_108] (rows=25/25 width=89)
                                   predicate:value is not null
-                                  TableScan [TS_21] (rows=25/25 width=89)
+                                  TableScan [TS_0] (rows=25/25 width=89)
+                                    Output:["value"]
+                          <-Map 6 [CONTAINS]
+                            Reduce Output Operator [RS_14]
+                              PartitionCols:_col0
+                              Select Operator [SEL_5] (rows=500/500 width=91)
+                                Output:["_col0"]
+                                Filter Operator [FIL_109] (rows=500/500 width=91)
+                                  predicate:value is not null
+                                  TableScan [TS_3] (rows=500/500 width=91)
                                     Output:["value"]
                 File Output Operator [FS_81]
                   table:{"name:":"default.b"}
-                   Please refer to the previous Select Operator [SEL_45]
+                   Please refer to the previous Select Operator [SEL_20]
                 File Output Operator [FS_83]
                   table:{"name:":"default.c"}
-                   Please refer to the previous Select Operator [SEL_45]
-              <-Reducer 19 [CONTAINS]
+                   Please refer to the previous Select Operator [SEL_20]
+              <-Reducer 9 [CONTAINS]
                 File Output Operator [FS_79]
                   table:{"name:":"default.a"}
                   Select Operator [SEL_76] (rows=313/820 width=175)
                     Output:["_col0","_col1"]
                     Merge Join Operator [MERGEJOIN_128] (rows=313/820 width=175)
-                      Conds:RS_73._col1=Union 22._col0(Inner),Output:["_col0","_col3"]
-                    <-Reducer 18 [SIMPLE_EDGE]
+                      Conds:RS_73._col1=Union 20._col0(Inner),Output:["_col0","_col3"]
+                    <-Reducer 8 [SIMPLE_EDGE]
                       SHUFFLE [RS_73]
                         PartitionCols:_col1
                         Merge Join Operator [MERGEJOIN_127] (rows=44/115 width=264)
                           Conds:RS_70._col0=RS_71._col0(Inner),Output:["_col0","_col1","_col3"]
-                        <-Map 17 [SIMPLE_EDGE]
+                        <-Map 7 [SIMPLE_EDGE]
                           SHUFFLE [RS_70]
                             PartitionCols:_col0
                             Select Operator [SEL_50] (rows=25/25 width=175)
                               Output:["_col0","_col1"]
                               Filter Operator [FIL_117] (rows=25/25 width=175)
                                 predicate:(key is not null and value is not null)
-                                TableScan [TS_48] (rows=25/25 width=175)
-                                  default@src1,x,Tbl:COMPLETE,Col:COMPLETE,Output:["key","value"]
-                        <-Map 20 [SIMPLE_EDGE]
+                                 Please refer to the previous TableScan [TS_8]
+                        <-Map 18 [SIMPLE_EDGE]
                           SHUFFLE [RS_71]
                             PartitionCols:_col0
                             Select Operator [SEL_53] (rows=25/25 width=175)
@@ -1245,8 +1294,8 @@ Stage-5
                                 predicate:key is not null
                                 TableScan [TS_51] (rows=25/25 width=175)
                                   default@src1,y,Tbl:COMPLETE,Col:COMPLETE,Output:["key","value"]
-                    <-Union 22 [SIMPLE_EDGE]
-                      <-Map 21 [CONTAINS]
+                    <-Union 20 [SIMPLE_EDGE]
+                      <-Map 19 [CONTAINS]
                         Reduce Output Operator [RS_74]
                           PartitionCols:_col0
                           Select Operator [SEL_56] (rows=25/25 width=89)
@@ -1255,7 +1304,7 @@ Stage-5
                               predicate:value is not null
                               TableScan [TS_54] (rows=25/25 width=89)
                                 Output:["value"]
-                      <-Map 23 [CONTAINS]
+                      <-Map 21 [CONTAINS]
                         Reduce Output Operator [RS_74]
                           PartitionCols:_col0
                           Select Operator [SEL_59] (rows=500/500 width=91)
@@ -1264,7 +1313,7 @@ Stage-5
                               predicate:value is not null
                               TableScan [TS_57] (rows=500/500 width=91)
                                 Output:["value"]
-                      <-Map 24 [CONTAINS]
+                      <-Map 22 [CONTAINS]
                         Reduce Output Operator [RS_74]
                           PartitionCols:_col0
                           Select Operator [SEL_64] (rows=500/500 width=91)
@@ -1273,7 +1322,7 @@ Stage-5
                               predicate:value is not null
                               TableScan [TS_62] (rows=500/500 width=91)
                                 Output:["value"]
-                      <-Map 25 [CONTAINS]
+                      <-Map 23 [CONTAINS]
                         Reduce Output Operator [RS_74]
                           PartitionCols:_col0
                           Select Operator [SEL_68] (rows=500/500 width=91)
@@ -1288,61 +1337,6 @@ Stage-5
                 File Output Operator [FS_83]
                   table:{"name:":"default.c"}
                    Please refer to the previous Select Operator [SEL_76]
-              <-Reducer 4 [CONTAINS]
-                File Output Operator [FS_79]
-                  table:{"name:":"default.a"}
-                  Select Operator [SEL_20] (rows=148/170 width=177)
-                    Output:["_col0","_col1"]
-                    Merge Join Operator [MERGEJOIN_124] (rows=148/170 width=177)
-                      Conds:RS_17._col1=RS_18._col0(Inner),Output:["_col1","_col4"]
-                    <-Map 8 [SIMPLE_EDGE]
-                      SHUFFLE [RS_18]
-                        PartitionCols:_col0
-                        Select Operator [SEL_13] (rows=500/500 width=178)
-                          Output:["_col0","_col1"]
-                          Filter Operator [FIL_111] (rows=500/500 width=178)
-                            predicate:key is not null
-                            TableScan [TS_11] (rows=500/500 width=178)
-                              default@src,y,Tbl:COMPLETE,Col:COMPLETE,Output:["key","value"]
-                    <-Reducer 3 [SIMPLE_EDGE]
-                      SHUFFLE [RS_17]
-                        PartitionCols:_col1
-                        Merge Join Operator [MERGEJOIN_123] (rows=61/108 width=86)
-                          Conds:Union 2._col0=RS_15._col1(Inner),Output:["_col1"]
-                        <-Map 7 [SIMPLE_EDGE]
-                          SHUFFLE [RS_15]
-                            PartitionCols:_col1
-                            Select Operator [SEL_10] (rows=25/25 width=175)
-                              Output:["_col0","_col1"]
-                              Filter Operator [FIL_110] (rows=25/25 width=175)
-                                predicate:(key is not null and value is not null)
-                                TableScan [TS_8] (rows=25/25 width=175)
-                                  default@src1,x,Tbl:COMPLETE,Col:COMPLETE,Output:["key","value"]
-                        <-Union 2 [SIMPLE_EDGE]
-                          <-Map 1 [CONTAINS]
-                            Reduce Output Operator [RS_14]
-                              PartitionCols:_col0
-                              Select Operator [SEL_2] (rows=25/25 width=89)
-                                Output:["_col0"]
-                                Filter Operator [FIL_108] (rows=25/25 width=89)
-                                  predicate:value is not null
-                                  TableScan [TS_0] (rows=25/25 width=89)
-                                    Output:["value"]
-                          <-Map 6 [CONTAINS]
-                            Reduce Output Operator [RS_14]
-                              PartitionCols:_col0
-                              Select Operator [SEL_5] (rows=500/500 width=91)
-                                Output:["_col0"]
-                                Filter Operator [FIL_109] (rows=500/500 width=91)
-                                  predicate:value is not null
-                                  TableScan [TS_3] (rows=500/500 width=91)
-                                    Output:["value"]
-                File Output Operator [FS_81]
-                  table:{"name:":"default.b"}
-                   Please refer to the previous Select Operator [SEL_20]
-                File Output Operator [FS_83]
-                  table:{"name:":"default.c"}
-                   Please refer to the previous Select Operator [SEL_20]
 Stage-6
   Stats-Aggr Operator
     Stage-1
@@ -1433,25 +1427,25 @@ Plan optimized by CBO.
 Vertex dependency in root stage
 Map 1 <- Union 2 (CONTAINS)
 Map 10 <- Union 2 (CONTAINS)
-Map 13 <- Union 14 (CONTAINS)
-Map 20 <- Union 14 (CONTAINS)
-Map 21 <- Union 16 (CONTAINS)
-Map 28 <- Union 29 (CONTAINS)
-Map 35 <- Union 29 (CONTAINS)
-Map 36 <- Union 31 (CONTAINS)
-Map 37 <- Union 33 (CONTAINS)
-Reducer 15 <- Union 14 (SIMPLE_EDGE), Union 16 (CONTAINS)
-Reducer 17 <- Union 16 (SIMPLE_EDGE)
-Reducer 18 <- Map 22 (SIMPLE_EDGE), Reducer 17 (SIMPLE_EDGE)
-Reducer 19 <- Map 23 (SIMPLE_EDGE), Reducer 18 (SIMPLE_EDGE), Union 6 (CONTAINS)
-Reducer 25 <- Map 24 (SIMPLE_EDGE), Map 27 (SIMPLE_EDGE)
-Reducer 26 <- Reducer 25 (SIMPLE_EDGE), Reducer 34 (SIMPLE_EDGE), Union 8 (CONTAINS)
+Map 17 <- Union 18 (CONTAINS)
+Map 22 <- Union 18 (CONTAINS)
+Map 23 <- Union 20 (CONTAINS)
+Map 26 <- Union 27 (CONTAINS)
+Map 33 <- Union 27 (CONTAINS)
+Map 34 <- Union 29 (CONTAINS)
+Map 35 <- Union 31 (CONTAINS)
+Reducer 12 <- Map 11 (SIMPLE_EDGE), Map 25 (SIMPLE_EDGE)
+Reducer 13 <- Reducer 12 (SIMPLE_EDGE), Reducer 32 (SIMPLE_EDGE), Union 8 (CONTAINS)
+Reducer 15 <- Map 14 (SIMPLE_EDGE), Reducer 21 (SIMPLE_EDGE)
+Reducer 16 <- Map 24 (SIMPLE_EDGE), Reducer 15 (SIMPLE_EDGE), Union 6 (CONTAINS)
+Reducer 19 <- Union 18 (SIMPLE_EDGE), Union 20 (CONTAINS)
+Reducer 21 <- Union 20 (SIMPLE_EDGE)
+Reducer 28 <- Union 27 (SIMPLE_EDGE), Union 29 (CONTAINS)
 Reducer 3 <- Union 2 (SIMPLE_EDGE)
 Reducer 30 <- Union 29 (SIMPLE_EDGE), Union 31 (CONTAINS)
-Reducer 32 <- Union 31 (SIMPLE_EDGE), Union 33 (CONTAINS)
-Reducer 34 <- Union 33 (SIMPLE_EDGE)
+Reducer 32 <- Union 31 (SIMPLE_EDGE)
 Reducer 4 <- Map 11 (SIMPLE_EDGE), Reducer 3 (SIMPLE_EDGE)
-Reducer 5 <- Map 12 (SIMPLE_EDGE), Reducer 4 (SIMPLE_EDGE), Union 6 (CONTAINS)
+Reducer 5 <- Map 14 (SIMPLE_EDGE), Reducer 4 (SIMPLE_EDGE), Union 6 (CONTAINS)
 Reducer 7 <- Union 6 (SIMPLE_EDGE), Union 8 (CONTAINS)
 Reducer 9 <- Union 8 (SIMPLE_EDGE)
 
@@ -1469,28 +1463,28 @@ Stage-5
                 Group By Operator [GBY_112] (rows=6300/319 width=178)
                   Output:["_col0","_col1"],keys:KEY._col0, KEY._col1
                 <-Union 8 [SIMPLE_EDGE]
-                  <-Reducer 26 [CONTAINS]
+                  <-Reducer 13 [CONTAINS]
                     Reduce Output Operator [RS_111]
                       PartitionCols:_col0, _col1
                       Select Operator [SEL_107] (rows=313/304 width=175)
                         Output:["_col0","_col1"]
                         Merge Join Operator [MERGEJOIN_164] (rows=313/304 width=175)
                           Conds:RS_104._col1=RS_105._col1(Inner),Output:["_col0","_col3"]
-                        <-Reducer 25 [SIMPLE_EDGE]
+                        <-Reducer 12 [SIMPLE_EDGE]
                           SHUFFLE [RS_104]
                             PartitionCols:_col1
                             Merge Join Operator [MERGEJOIN_163] (rows=44/115 width=264)
                               Conds:RS_101._col0=RS_102._col0(Inner),Output:["_col0","_col1","_col3"]
-                            <-Map 24 [SIMPLE_EDGE]
+                            <-Map 11 [SIMPLE_EDGE]
                               SHUFFLE [RS_101]
                                 PartitionCols:_col0
                                 Select Operator [SEL_67] (rows=25/25 width=175)
                                   Output:["_col0","_col1"]
                                   Filter Operator [FIL_153] (rows=25/25 width=175)
                                     predicate:(key is not null and value is not null)
-                                    TableScan [TS_65] (rows=25/25 width=175)
+                                    TableScan [TS_12] (rows=25/25 width=175)
                                       default@src1,x,Tbl:COMPLETE,Col:COMPLETE,Output:["key","value"]
-                            <-Map 27 [SIMPLE_EDGE]
+                            <-Map 25 [SIMPLE_EDGE]
                               SHUFFLE [RS_102]
                                 PartitionCols:_col0
                                 Select Operator [SEL_70] (rows=25/25 width=175)
@@ -1499,15 +1493,15 @@ Stage-5
                                     predicate:key is not null
                                     TableScan [TS_68] (rows=25/25 width=175)
                                       default@src1,y,Tbl:COMPLETE,Col:COMPLETE,Output:["key","value"]
-                        <-Reducer 34 [SIMPLE_EDGE]
+                        <-Reducer 32 [SIMPLE_EDGE]
                           SHUFFLE [RS_105]
                             PartitionCols:_col1
                             Select Operator [SEL_100] (rows=1525/319 width=178)
                               Output:["_col1"]
                               Group By Operator [GBY_99] (rows=1525/319 width=178)
                                 Output:["_col0","_col1"],keys:KEY._col0, KEY._col1
-                              <-Union 33 [SIMPLE_EDGE]
-                                <-Map 37 [CONTAINS]
+                              <-Union 31 [SIMPLE_EDGE]
+                                <-Map 35 [CONTAINS]
                                   Reduce Output Operator [RS_98]
                                     PartitionCols:_col1, _col0
                                     Select Operator [SEL_94] (rows=500/500 width=178)
@@ -1516,15 +1510,15 @@ Stage-5
                                         predicate:value is not null
                                         TableScan [TS_92] (rows=500/500 width=178)
                                           Output:["key","value"]
-                                <-Reducer 32 [CONTAINS]
+                                <-Reducer 30 [CONTAINS]
                                   Reduce Output Operator [RS_98]
                                     PartitionCols:_col1, _col0
                                     Select Operator [SEL_91] (rows=1025/319 width=178)
                                       Output:["_col0","_col1"]
                                       Group By Operator [GBY_90] (rows=1025/319 width=178)
                                         Output:["_col0","_col1"],keys:KEY._col0, KEY._col1
-                                      <-Union 31 [SIMPLE_EDGE]
-                                        <-Map 36 [CONTAINS]
+                                      <-Union 29 [SIMPLE_EDGE]
+                                        <-Map 34 [CONTAINS]
                                           Reduce Output Operator [RS_89]
                                             PartitionCols:_col1, _col0
                                             Select Operator [SEL_85] (rows=500/500 width=178)
@@ -1533,15 +1527,15 @@ Stage-5
                                                 predicate:value is not null
                                                 TableScan [TS_83] (rows=500/500 width=178)
                                                   Output:["key","value"]
-                                        <-Reducer 30 [CONTAINS]
+                                        <-Reducer 28 [CONTAINS]
                                           Reduce Output Operator [RS_89]
                                             PartitionCols:_col1, _col0
                                             Select Operator [SEL_82] (rows=525/319 width=178)
                                               Output:["_col0","_col1"]
                                               Group By Operator [GBY_81] (rows=525/319 width=178)
                                                 Output:["_col0","_col1"],keys:KEY._col0, KEY._col1
-                                              <-Union 29 [SIMPLE_EDGE]
-                                                <-Map 28 [CONTAINS]
+                                              <-Union 27 [SIMPLE_EDGE]
+                                                <-Map 26 [CONTAINS]
                                                   Reduce Output Operator [RS_80]
                                                     PartitionCols:_col1, _col0
                                                     Select Operator [SEL_73] (rows=25/25 width=175)
@@ -1550,7 +1544,7 @@ Stage-5
                                                         predicate:value is not null
                                                         TableScan [TS_71] (rows=25/25 width=175)
                                                           Output:["key","value"]
-                                                <-Map 35 [CONTAINS]
+                                                <-Map 33 [CONTAINS]
                                                   Reduce Output Operator [RS_80]
                                                     PartitionCols:_col1, _col0
                                                     Select Operator [SEL_76] (rows=500/500 width=178)
@@ -1565,14 +1559,14 @@ Stage-5
                       Group By Operator [GBY_63] (rows=5987/309 width=178)
                         Output:["_col0","_col1"],keys:KEY._col0, KEY._col1
                       <-Union 6 [SIMPLE_EDGE]
-                        <-Reducer 19 [CONTAINS]
+                        <-Reducer 16 [CONTAINS]
                           Reduce Output Operator [RS_62]
                             PartitionCols:_col0, _col1
                             Select Operator [SEL_58] (rows=5839/1056 width=178)
                               Output:["_col0","_col1"]
                               Merge Join Operator [MERGEJOIN_162] (rows=5839/1056 width=178)
                                 Conds:RS_55._col2=RS_56._col0(Inner),Output:["_col2","_col5"]
-                              <-Map 23 [SIMPLE_EDGE]
+                              <-Map 24 [SIMPLE_EDGE]
                                 SHUFFLE [RS_56]
                                   PartitionCols:_col0
                                   Select Operator [SEL_51] (rows=500/500 width=178)
@@ -1581,29 +1575,29 @@ Stage-5
                                       predicate:key is not null
                                       TableScan [TS_49] (rows=500/500 width=178)
                                         default@src,y,Tbl:COMPLETE,Col:COMPLETE,Output:["key","value"]
-                              <-Reducer 18 [SIMPLE_EDGE]
+                              <-Reducer 15 [SIMPLE_EDGE]
                                 SHUFFLE [RS_55]
                                   PartitionCols:_col2
                                   Merge Join Operator [MERGEJOIN_161] (rows=2394/512 width=87)
                                     Conds:RS_52._col1=RS_53._col1(Inner),Output:["_col2"]
-                                  <-Map 22 [SIMPLE_EDGE]
+                                  <-Map 14 [SIMPLE_EDGE]
                                     SHUFFLE [RS_53]
                                       PartitionCols:_col1
                                       Select Operator [SEL_48] (rows=500/500 width=178)
                                         Output:["_col0","_col1"]
                                         Filter Operator [FIL_151] (rows=500/500 width=178)
                                           predicate:(key is not null and value is not null)
-                                          TableScan [TS_46] (rows=500/500 width=178)
-                                            default@src,x,Tbl:COMPLETE,Col:COMPLETE,Output:["key","value"]
-                                  <-Reducer 17 [SIMPLE_EDGE]
+                                          TableScan [TS_15] (rows=500/500 width=178)
+                                            default@src,y,Tbl:COMPLETE,Col:COMPLETE,Output:["key","value"]
+                                  <-Reducer 21 [SIMPLE_EDGE]
                                     SHUFFLE [RS_52]
                                       PartitionCols:_col1
                                       Select Operator [SEL_45] (rows=1025/319 width=178)
                                         Output:["_col1"]
                                         Group By Operator [GBY_44] (rows=1025/319 width=178)
                                           Output:["_col0","_col1"],keys:KEY._col0, KEY._col1
-                                        <-Union 16 [SIMPLE_EDGE]
-                                          <-Map 21 [CONTAINS]
+                                        <-Union 20 [SIMPLE_EDGE]
+                                          <-Map 23 [CONTAINS]
                                             Reduce Output Operator [RS_43]
                                               PartitionCols:_col1, _col0
                                               Select Operator [SEL_39] (rows=500/500 width=178)
@@ -1612,15 +1606,15 @@ Stage-5
                                                   predicate:value is not null
                                                   TableScan [TS_37] (rows=500/500 width=178)
                                                     Output:["key","value"]
-                                          <-Reducer 15 [CONTAINS]
+                                          <-Reducer 19 [CONTAINS]
                                             Reduce Output Operator [RS_43]
                                               PartitionCols:_col1, _col0
                                               Select Operator [SEL_36] (rows=525/319 width=178)
                                                 Output:["_col0","_col1"]
                                                 Group By Operator [GBY_35] (rows=525/319 width=178)
                                                   Output:["_col0","_col1"],keys:KEY._col0, KEY._col1
-                                                <-Union 14 [SIMPLE_EDGE]
-                                                  <-Map 13 [CONTAINS]
+                                                <-Union 18 [SIMPLE_EDGE]
+                                                  <-Map 17 [CONTAINS]
                                                     Reduce Output Operator [RS_34]
                                                       PartitionCols:_col1, _col0
                                                       Select Operator [SEL_27] (rows=25/25 width=175)
@@ -1629,7 +1623,7 @@ Stage-5
                                                           predicate:value is not null
                                                           TableScan [TS_25] (rows=25/25 width=175)
                                                             Output:["key","value"]
-                                                  <-Map 20 [CONTAINS]
+                                                  <-Map 22 [CONTAINS]
                                                     Reduce Output Operator [RS_34]
                                                       PartitionCols:_col1, _col0
                                                       Select Operator [SEL_30] (rows=500/500 width=178)
@@ -1645,15 +1639,14 @@ Stage-5
                               Output:["_col0","_col1"]
                               Merge Join Operator [MERGEJOIN_160] (rows=148/61 width=177)
                                 Conds:RS_21._col2=RS_22._col0(Inner),Output:["_col2","_col5"]
-                              <-Map 12 [SIMPLE_EDGE]
+                              <-Map 14 [SIMPLE_EDGE]
                                 SHUFFLE [RS_22]
                                   PartitionCols:_col0
                                   Select Operator [SEL_17] (rows=500/500 width=178)
                                     Output:["_col0","_col1"]
                                     Filter Operator [FIL_147] (rows=500/500 width=178)
                                       predicate:key is not null
-                                      TableScan [TS_15] (rows=500/500 width=178)
-                                        default@src,y,Tbl:COMPLETE,Col:COMPLETE,Output:["key","value"]
+                                       Please refer to the previous TableScan [TS_15]
                               <-Reducer 4 [SIMPLE_EDGE]
                                 SHUFFLE [RS_21]
                                   PartitionCols:_col2
@@ -1666,8 +1659,7 @@ Stage-5
                                         Output:["_col0","_col1"]
                                         Filter Operator [FIL_146] (rows=25/25 width=175)
                                           predicate:(key is not null and value is not null)
-                                          TableScan [TS_12] (rows=25/25 width=175)
-                                            default@src1,x,Tbl:COMPLETE,Col:COMPLETE,Output:["key","value"]
+                                           Please refer to the previous TableScan [TS_12]
                                   <-Reducer 3 [SIMPLE_EDGE]
                                     SHUFFLE [RS_18]
                                       PartitionCols:_col1

http://git-wip-us.apache.org/repos/asf/hive/blob/59f65772/ql/src/test/results/clientpositive/tez/explainanalyze_3.q.out
----------------------------------------------------------------------
diff --git a/ql/src/test/results/clientpositive/tez/explainanalyze_3.q.out b/ql/src/test/results/clientpositive/tez/explainanalyze_3.q.out
index 087f916..e5c8d6c 100644
--- a/ql/src/test/results/clientpositive/tez/explainanalyze_3.q.out
+++ b/ql/src/test/results/clientpositive/tez/explainanalyze_3.q.out
@@ -827,7 +827,7 @@ POSTHOOK: type: QUERY
 Plan optimized by CBO.
 
 Vertex dependency in root stage
-Map 2 <- Map 1 (CUSTOM_EDGE)
+Map 2 <- Map 1 (BROADCAST_EDGE)
 
 Stage-0
   Fetch Operator
@@ -838,9 +838,9 @@ Stage-0
         Select Operator [SEL_9] (rows=550/480 width=18)
           Output:["_col0","_col1","_col2"]
           Map Join Operator [MAPJOIN_25] (rows=550/480 width=18)
-            BucketMapJoin:true,Conds:RS_6._col0=SEL_5._col0(Inner),HybridGraceHashJoin:true,Output:["_col0","_col1","_col3"]
-          <-Map 1 [CUSTOM_EDGE]
-            MULTICAST [RS_6]
+            Conds:RS_6._col0=SEL_5._col0(Inner),HybridGraceHashJoin:true,Output:["_col0","_col1","_col3"]
+          <-Map 1 [BROADCAST_EDGE]
+            BROADCAST [RS_6]
               PartitionCols:_col0
               Select Operator [SEL_2] (rows=242/242 width=18)
                 Output:["_col0","_col1"]

http://git-wip-us.apache.org/repos/asf/hive/blob/59f65772/ql/src/test/results/clientpositive/tez/explainuser_3.q.out
----------------------------------------------------------------------
diff --git a/ql/src/test/results/clientpositive/tez/explainuser_3.q.out b/ql/src/test/results/clientpositive/tez/explainuser_3.q.out
index adcff44..65c9114 100644
--- a/ql/src/test/results/clientpositive/tez/explainuser_3.q.out
+++ b/ql/src/test/results/clientpositive/tez/explainuser_3.q.out
@@ -655,7 +655,7 @@ POSTHOOK: type: QUERY
 Plan optimized by CBO.
 
 Vertex dependency in root stage
-Map 2 <- Map 1 (CUSTOM_EDGE)
+Map 2 <- Map 1 (BROADCAST_EDGE)
 
 Stage-0
   Fetch Operator
@@ -666,9 +666,9 @@ Stage-0
         Select Operator [SEL_33] (rows=550 width=18)
           Output:["_col0","_col1","_col2"]
           Map Join Operator [MAPJOIN_32] (rows=550 width=18)
-            BucketMapJoin:true,Conds:RS_29._col0=SEL_31._col0(Inner),HybridGraceHashJoin:true,Output:["_col0","_col1","_col3"]
-          <-Map 1 [CUSTOM_EDGE] vectorized
-            MULTICAST [RS_29]
+            Conds:RS_29._col0=SEL_31._col0(Inner),HybridGraceHashJoin:true,Output:["_col0","_col1","_col3"]
+          <-Map 1 [BROADCAST_EDGE] vectorized
+            BROADCAST [RS_29]
               PartitionCols:_col0
               Select Operator [SEL_28] (rows=242 width=18)
                 Output:["_col0","_col1"]


Mime
View raw message