hive-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From hashut...@apache.org
Subject svn commit: r1674738 [9/11] - in /hive/trunk: ./ common/src/java/org/apache/hadoop/hive/conf/ hbase-handler/ metastore/bin/ ql/ ql/src/java/org/apache/hadoop/hive/ql/exec/ ql/src/java/org/apache/hadoop/hive/ql/optimizer/ ql/src/java/org/apache/hadoop/h...
Date Mon, 20 Apr 2015 06:14:39 GMT
Modified: hive/trunk/ql/src/test/results/clientpositive/tez/explainuser_2.q.out
URL: http://svn.apache.org/viewvc/hive/trunk/ql/src/test/results/clientpositive/tez/explainuser_2.q.out?rev=1674738&r1=1674737&r2=1674738&view=diff
==============================================================================
--- hive/trunk/ql/src/test/results/clientpositive/tez/explainuser_2.q.out (original)
+++ hive/trunk/ql/src/test/results/clientpositive/tez/explainuser_2.q.out Mon Apr 20 06:14:38 2015
@@ -53,11 +53,11 @@ POSTHOOK: Input: default@srcpart
 POSTHOOK: Input: default@srcpart@ds=2008-04-08/hr=11
 POSTHOOK: Output: default@ss
 POSTHOOK: Lineage: ss.k1 SIMPLE [(src1)x.FieldSchema(name:key, type:string, comment:default), ]
-POSTHOOK: Lineage: ss.k2 SIMPLE [(src)y.FieldSchema(name:key, type:string, comment:default), ]
-POSTHOOK: Lineage: ss.k3 EXPRESSION [(srcpart)z.FieldSchema(name:key, type:string, comment:default), ]
+POSTHOOK: Lineage: ss.k2 EXPRESSION [(src)y.FieldSchema(name:key, type:string, comment:default), ]
+POSTHOOK: Lineage: ss.k3 SIMPLE [(srcpart)z.FieldSchema(name:key, type:string, comment:default), ]
 POSTHOOK: Lineage: ss.v1 SIMPLE [(src1)x.FieldSchema(name:value, type:string, comment:default), ]
-POSTHOOK: Lineage: ss.v2 SIMPLE [(src)y.FieldSchema(name:value, type:string, comment:default), ]
-POSTHOOK: Lineage: ss.v3 EXPRESSION [(srcpart)z.FieldSchema(name:value, type:string, comment:default), ]
+POSTHOOK: Lineage: ss.v2 EXPRESSION [(src)y.FieldSchema(name:value, type:string, comment:default), ]
+POSTHOOK: Lineage: ss.v3 SIMPLE [(srcpart)z.FieldSchema(name:value, type:string, comment:default), ]
 PREHOOK: query: INSERT OVERWRITE TABLE sr
 SELECT x.key,x.value,y.key,y.value,z.key,z.value
 FROM src1 x 
@@ -81,11 +81,11 @@ POSTHOOK: Input: default@srcpart
 POSTHOOK: Input: default@srcpart@ds=2008-04-08/hr=12
 POSTHOOK: Output: default@sr
 POSTHOOK: Lineage: sr.k1 SIMPLE [(src1)x.FieldSchema(name:key, type:string, comment:default), ]
-POSTHOOK: Lineage: sr.k2 SIMPLE [(src)y.FieldSchema(name:key, type:string, comment:default), ]
-POSTHOOK: Lineage: sr.k3 EXPRESSION [(srcpart)z.FieldSchema(name:key, type:string, comment:default), ]
+POSTHOOK: Lineage: sr.k2 EXPRESSION [(src)y.FieldSchema(name:key, type:string, comment:default), ]
+POSTHOOK: Lineage: sr.k3 SIMPLE [(srcpart)z.FieldSchema(name:key, type:string, comment:default), ]
 POSTHOOK: Lineage: sr.v1 SIMPLE [(src1)x.FieldSchema(name:value, type:string, comment:default), ]
-POSTHOOK: Lineage: sr.v2 SIMPLE [(src)y.FieldSchema(name:value, type:string, comment:default), ]
-POSTHOOK: Lineage: sr.v3 EXPRESSION [(srcpart)z.FieldSchema(name:value, type:string, comment:default), ]
+POSTHOOK: Lineage: sr.v2 EXPRESSION [(src)y.FieldSchema(name:value, type:string, comment:default), ]
+POSTHOOK: Lineage: sr.v3 SIMPLE [(srcpart)z.FieldSchema(name:value, type:string, comment:default), ]
 PREHOOK: query: INSERT OVERWRITE TABLE cs
 SELECT x.key,x.value,y.key,y.value,z.key,z.value
 FROM src1 x 
@@ -195,7 +195,7 @@ Stage-0
                Merge Join Operator [MERGEJOIN_29]
                |  condition map:[{"":"Inner Join 0 to 1"}]
                |  keys:{"1":"_col3 (type: string)","0":"_col0 (type: string)"}
-               |  outputColumnNames:["_col1","_col2","_col5"]
+               |  outputColumnNames:["_col0","_col4","_col5"]
                |  Statistics:Num rows: 302 Data size: 3213 Basic stats: COMPLETE Column stats: NONE
                |<-Map 1 [SIMPLE_EDGE]
                |  Reduce Output Operator [RS_14]
@@ -203,15 +203,14 @@ Stage-0
                |     Map-reduce partition columns:_col0 (type: string)
                |     sort order:+
                |     Statistics:Num rows: 250 Data size: 2656 Basic stats: COMPLETE Column stats: NONE
-               |     value expressions:_col1 (type: string)
-               |     Select Operator [SEL_1]
-               |        outputColumnNames:["_col0","_col1"]
+               |     Select Operator [SEL_2]
+               |        outputColumnNames:["_col0"]
                |        Statistics:Num rows: 250 Data size: 2656 Basic stats: COMPLETE Column stats: NONE
                |        Filter Operator [FIL_25]
-               |           predicate:key is not null (type: boolean)
+               |           predicate:value is not null (type: boolean)
                |           Statistics:Num rows: 250 Data size: 2656 Basic stats: COMPLETE Column stats: NONE
                |           TableScan [TS_0]
-               |              alias:y
+               |              alias:z
                |              Statistics:Num rows: 500 Data size: 5312 Basic stats: COMPLETE Column stats: NONE
                |<-Reducer 4 [SIMPLE_EDGE]
                   Reduce Output Operator [RS_16]
@@ -219,11 +218,11 @@ Stage-0
                      Map-reduce partition columns:_col3 (type: string)
                      sort order:+
                      Statistics:Num rows: 275 Data size: 2921 Basic stats: COMPLETE Column stats: NONE
-                     value expressions:_col0 (type: string)
+                     value expressions:_col1 (type: string), _col2 (type: string)
                      Merge Join Operator [MERGEJOIN_28]
                      |  condition map:[{"":"Inner Join 0 to 1"}]
-                     |  keys:{"1":"_col1 (type: string)","0":"_col0 (type: string)"}
-                     |  outputColumnNames:["_col0","_col3"]
+                     |  keys:{"1":"_col0 (type: string)","0":"_col0 (type: string)"}
+                     |  outputColumnNames:["_col1","_col2","_col3"]
                      |  Statistics:Num rows: 275 Data size: 2921 Basic stats: COMPLETE Column stats: NONE
                      |<-Map 3 [SIMPLE_EDGE]
                      |  Reduce Output Operator [RS_8]
@@ -231,27 +230,28 @@ Stage-0
                      |     Map-reduce partition columns:_col0 (type: string)
                      |     sort order:+
                      |     Statistics:Num rows: 250 Data size: 2656 Basic stats: COMPLETE Column stats: NONE
+                     |     value expressions:_col1 (type: string)
                      |     Select Operator [SEL_4]
-                     |        outputColumnNames:["_col0"]
+                     |        outputColumnNames:["_col0","_col1"]
                      |        Statistics:Num rows: 250 Data size: 2656 Basic stats: COMPLETE Column stats: NONE
                      |        Filter Operator [FIL_26]
-                     |           predicate:value is not null (type: boolean)
+                     |           predicate:key is not null (type: boolean)
                      |           Statistics:Num rows: 250 Data size: 2656 Basic stats: COMPLETE Column stats: NONE
-                     |           TableScan [TS_2]
-                     |              alias:z
+                     |           TableScan [TS_3]
+                     |              alias:y
                      |              Statistics:Num rows: 500 Data size: 5312 Basic stats: COMPLETE Column stats: NONE
                      |<-Map 5 [SIMPLE_EDGE]
                         Reduce Output Operator [RS_10]
-                           key expressions:_col1 (type: string)
-                           Map-reduce partition columns:_col1 (type: string)
+                           key expressions:_col0 (type: string)
+                           Map-reduce partition columns:_col0 (type: string)
                            sort order:+
                            Statistics:Num rows: 7 Data size: 53 Basic stats: COMPLETE Column stats: NONE
-                           value expressions:_col0 (type: string)
+                           value expressions:_col1 (type: string)
                            Select Operator [SEL_6]
                               outputColumnNames:["_col0","_col1"]
                               Statistics:Num rows: 7 Data size: 53 Basic stats: COMPLETE Column stats: NONE
                               Filter Operator [FIL_27]
-                                 predicate:(value is not null and key is not null) (type: boolean)
+                                 predicate:(key is not null and value is not null) (type: boolean)
                                  Statistics:Num rows: 7 Data size: 53 Basic stats: COMPLETE Column stats: NONE
                                  TableScan [TS_5]
                                     alias:x
@@ -315,21 +315,21 @@ POSTHOOK: type: QUERY
 Plan optimized by CBO.
 
 Vertex dependency in root stage
-Reducer 2 <- Map 1 (SIMPLE_EDGE), Map 6 (SIMPLE_EDGE)
-Reducer 13 <- Map 12 (SIMPLE_EDGE), Map 14 (SIMPLE_EDGE)
+Reducer 2 <- Map 1 (SIMPLE_EDGE), Map 7 (SIMPLE_EDGE)
 Reducer 3 <- Reducer 2 (SIMPLE_EDGE), Reducer 9 (SIMPLE_EDGE)
-Reducer 11 <- Map 10 (SIMPLE_EDGE), Reducer 13 (SIMPLE_EDGE)
+Reducer 14 <- Map 13 (SIMPLE_EDGE), Reducer 16 (SIMPLE_EDGE)
+Reducer 12 <- Map 11 (SIMPLE_EDGE), Reducer 14 (SIMPLE_EDGE)
 Reducer 5 <- Reducer 4 (SIMPLE_EDGE)
-Reducer 4 <- Reducer 3 (SIMPLE_EDGE)
-Reducer 9 <- Reducer 16 (SIMPLE_EDGE), Reducer 8 (SIMPLE_EDGE)
-Reducer 8 <- Map 7 (SIMPLE_EDGE), Reducer 11 (SIMPLE_EDGE)
+Reducer 4 <- Reducer 12 (SIMPLE_EDGE), Reducer 3 (SIMPLE_EDGE)
+Reducer 6 <- Reducer 5 (SIMPLE_EDGE)
+Reducer 9 <- Map 10 (SIMPLE_EDGE), Map 8 (SIMPLE_EDGE)
 Reducer 16 <- Map 15 (SIMPLE_EDGE), Map 17 (SIMPLE_EDGE)
 
 Stage-0
    Fetch Operator
       limit:100
       Stage-1
-         Reducer 5
+         Reducer 6
          File Output Operator [FS_71]
             compressed:false
             Statistics:Num rows: 100 Data size: 1000 Basic stats: COMPLETE Column stats: NONE
@@ -339,236 +339,236 @@ Stage-0
                Statistics:Num rows: 100 Data size: 1000 Basic stats: COMPLETE Column stats: NONE
                Select Operator [SEL_69]
                |  outputColumnNames:["_col0","_col1","_col2","_col3","_col4","_col5"]
-               |  Statistics:Num rows: 402 Data size: 4276 Basic stats: COMPLETE Column stats: NONE
-               |<-Reducer 4 [SIMPLE_EDGE]
+               |  Statistics:Num rows: 365 Data size: 3882 Basic stats: COMPLETE Column stats: NONE
+               |<-Reducer 5 [SIMPLE_EDGE]
                   Reduce Output Operator [RS_68]
                      key expressions:_col0 (type: string), _col1 (type: string), _col2 (type: string)
                      sort order:+++
-                     Statistics:Num rows: 402 Data size: 4276 Basic stats: COMPLETE Column stats: NONE
+                     Statistics:Num rows: 365 Data size: 3882 Basic stats: COMPLETE Column stats: NONE
                      value expressions:_col3 (type: bigint), _col4 (type: bigint), _col5 (type: bigint)
                      Group By Operator [GBY_66]
                      |  aggregations:["count(VALUE._col0)","count(VALUE._col1)","count(VALUE._col2)"]
                      |  keys:KEY._col0 (type: string), KEY._col1 (type: string), KEY._col2 (type: string)
                      |  outputColumnNames:["_col0","_col1","_col2","_col3","_col4","_col5"]
-                     |  Statistics:Num rows: 402 Data size: 4276 Basic stats: COMPLETE Column stats: NONE
-                     |<-Reducer 3 [SIMPLE_EDGE]
+                     |  Statistics:Num rows: 365 Data size: 3882 Basic stats: COMPLETE Column stats: NONE
+                     |<-Reducer 4 [SIMPLE_EDGE]
                         Reduce Output Operator [RS_65]
                            key expressions:_col0 (type: string), _col1 (type: string), _col2 (type: string)
                            Map-reduce partition columns:_col0 (type: string), _col1 (type: string), _col2 (type: string)
                            sort order:+++
-                           Statistics:Num rows: 804 Data size: 8552 Basic stats: COMPLETE Column stats: NONE
+                           Statistics:Num rows: 731 Data size: 7775 Basic stats: COMPLETE Column stats: NONE
                            value expressions:_col3 (type: bigint), _col4 (type: bigint), _col5 (type: bigint)
                            Group By Operator [GBY_64]
                               aggregations:["count(_col3)","count(_col4)","count(_col5)"]
                               keys:_col0 (type: string), _col1 (type: string), _col2 (type: string)
                               outputColumnNames:["_col0","_col1","_col2","_col3","_col4","_col5"]
-                              Statistics:Num rows: 804 Data size: 8552 Basic stats: COMPLETE Column stats: NONE
+                              Statistics:Num rows: 731 Data size: 7775 Basic stats: COMPLETE Column stats: NONE
                               Select Operator [SEL_62]
                                  outputColumnNames:["_col0","_col1","_col2","_col3","_col4","_col5"]
-                                 Statistics:Num rows: 804 Data size: 8552 Basic stats: COMPLETE Column stats: NONE
-                                 Merge Join Operator [MERGEJOIN_113]
+                                 Statistics:Num rows: 731 Data size: 7775 Basic stats: COMPLETE Column stats: NONE
+                                 Merge Join Operator [MERGEJOIN_111]
                                  |  condition map:[{"":"Inner Join 0 to 1"}]
-                                 |  keys:{"1":"_col15 (type: string), _col17 (type: string)","0":"_col1 (type: string), _col3 (type: string)"}
-                                 |  outputColumnNames:["_col2","_col3","_col12","_col13","_col20","_col21"]
-                                 |  Statistics:Num rows: 804 Data size: 8552 Basic stats: COMPLETE Column stats: NONE
-                                 |<-Reducer 2 [SIMPLE_EDGE]
-                                 |  Reduce Output Operator [RS_58]
-                                 |     key expressions:_col1 (type: string), _col3 (type: string)
-                                 |     Map-reduce partition columns:_col1 (type: string), _col3 (type: string)
+                                 |  keys:{"1":"_col8 (type: string), _col10 (type: string)","0":"_col8 (type: string), _col10 (type: string)"}
+                                 |  outputColumnNames:["_col2","_col3","_col8","_col9","_col20","_col21"]
+                                 |  Statistics:Num rows: 731 Data size: 7775 Basic stats: COMPLETE Column stats: NONE
+                                 |<-Reducer 12 [SIMPLE_EDGE]
+                                 |  Reduce Output Operator [RS_60]
+                                 |     key expressions:_col8 (type: string), _col10 (type: string)
+                                 |     Map-reduce partition columns:_col8 (type: string), _col10 (type: string)
                                  |     sort order:++
-                                 |     Statistics:Num rows: 137 Data size: 1460 Basic stats: COMPLETE Column stats: NONE
-                                 |     value expressions:_col2 (type: string)
-                                 |     Merge Join Operator [MERGEJOIN_107]
-                                 |     |  condition map:[{"":"Inner Join 0 to 1"}]
-                                 |     |  keys:{"1":"_col0 (type: string)","0":"_col0 (type: string)"}
-                                 |     |  outputColumnNames:["_col1","_col2","_col3"]
-                                 |     |  Statistics:Num rows: 137 Data size: 1460 Basic stats: COMPLETE Column stats: NONE
-                                 |     |<-Map 1 [SIMPLE_EDGE]
-                                 |     |  Reduce Output Operator [RS_53]
-                                 |     |     key expressions:_col0 (type: string)
-                                 |     |     Map-reduce partition columns:_col0 (type: string)
-                                 |     |     sort order:+
-                                 |     |     Statistics:Num rows: 22 Data size: 762 Basic stats: COMPLETE Column stats: NONE
-                                 |     |     value expressions:_col1 (type: string), _col2 (type: string), _col3 (type: string)
-                                 |     |     Select Operator [SEL_1]
-                                 |     |        outputColumnNames:["_col0","_col1","_col2","_col3"]
-                                 |     |        Statistics:Num rows: 22 Data size: 762 Basic stats: COMPLETE Column stats: NONE
-                                 |     |        Filter Operator [FIL_99]
-                                 |     |           predicate:((k1 is not null and v2 is not null) and v3 is not null) (type: boolean)
-                                 |     |           Statistics:Num rows: 22 Data size: 762 Basic stats: COMPLETE Column stats: NONE
-                                 |     |           TableScan [TS_0]
-                                 |     |              alias:cs
-                                 |     |              Statistics:Num rows: 170 Data size: 5890 Basic stats: COMPLETE Column stats: NONE
-                                 |     |<-Map 6 [SIMPLE_EDGE]
-                                 |        Reduce Output Operator [RS_55]
-                                 |           key expressions:_col0 (type: string)
-                                 |           Map-reduce partition columns:_col0 (type: string)
-                                 |           sort order:+
-                                 |           Statistics:Num rows: 125 Data size: 1328 Basic stats: COMPLETE Column stats: NONE
-                                 |           Select Operator [SEL_4]
-                                 |              outputColumnNames:["_col0"]
-                                 |              Statistics:Num rows: 125 Data size: 1328 Basic stats: COMPLETE Column stats: NONE
-                                 |              Filter Operator [FIL_100]
-                                 |                 predicate:((value) IN ('2000Q1', '2000Q2', '2000Q3') and key is not null) (type: boolean)
-                                 |                 Statistics:Num rows: 125 Data size: 1328 Basic stats: COMPLETE Column stats: NONE
-                                 |                 TableScan [TS_2]
-                                 |                    alias:d1
-                                 |                    Statistics:Num rows: 500 Data size: 5312 Basic stats: COMPLETE Column stats: NONE
-                                 |<-Reducer 9 [SIMPLE_EDGE]
-                                    Reduce Output Operator [RS_60]
-                                       key expressions:_col15 (type: string), _col17 (type: string)
-                                       Map-reduce partition columns:_col15 (type: string), _col17 (type: string)
+                                 |     Statistics:Num rows: 665 Data size: 7069 Basic stats: COMPLETE Column stats: NONE
+                                 |     value expressions:_col6 (type: string), _col7 (type: string)
+                                 |     Select Operator [SEL_46]
+                                 |        outputColumnNames:["_col10","_col6","_col7","_col8"]
+                                 |        Statistics:Num rows: 665 Data size: 7069 Basic stats: COMPLETE Column stats: NONE
+                                 |        Merge Join Operator [MERGEJOIN_109]
+                                 |        |  condition map:[{"":"Inner Join 0 to 1"}]
+                                 |        |  keys:{"1":"_col5 (type: string)","0":"_col1 (type: string)"}
+                                 |        |  outputColumnNames:["_col6","_col7","_col8","_col10"]
+                                 |        |  Statistics:Num rows: 665 Data size: 7069 Basic stats: COMPLETE Column stats: NONE
+                                 |        |<-Map 11 [SIMPLE_EDGE]
+                                 |        |  Reduce Output Operator [RS_42]
+                                 |        |     key expressions:_col1 (type: string)
+                                 |        |     Map-reduce partition columns:_col1 (type: string)
+                                 |        |     sort order:+
+                                 |        |     Statistics:Num rows: 6 Data size: 45 Basic stats: COMPLETE Column stats: NONE
+                                 |        |     Select Operator [SEL_19]
+                                 |        |        outputColumnNames:["_col1"]
+                                 |        |        Statistics:Num rows: 6 Data size: 45 Basic stats: COMPLETE Column stats: NONE
+                                 |        |        Filter Operator [FIL_101]
+                                 |        |           predicate:((key = 'src1key') and value is not null) (type: boolean)
+                                 |        |           Statistics:Num rows: 6 Data size: 45 Basic stats: COMPLETE Column stats: NONE
+                                 |        |           TableScan [TS_17]
+                                 |        |              alias:src1
+                                 |        |              Statistics:Num rows: 25 Data size: 191 Basic stats: COMPLETE Column stats: NONE
+                                 |        |<-Reducer 14 [SIMPLE_EDGE]
+                                 |           Reduce Output Operator [RS_44]
+                                 |              key expressions:_col5 (type: string)
+                                 |              Map-reduce partition columns:_col5 (type: string)
+                                 |              sort order:+
+                                 |              Statistics:Num rows: 605 Data size: 6427 Basic stats: COMPLETE Column stats: NONE
+                                 |              value expressions:_col4 (type: string), _col6 (type: string), _col8 (type: string)
+                                 |              Merge Join Operator [MERGEJOIN_108]
+                                 |              |  condition map:[{"":"Inner Join 0 to 1"}]
+                                 |              |  keys:{"1":"_col2 (type: string)","0":"_col0 (type: string)"}
+                                 |              |  outputColumnNames:["_col4","_col5","_col6","_col8"]
+                                 |              |  Statistics:Num rows: 605 Data size: 6427 Basic stats: COMPLETE Column stats: NONE
+                                 |              |<-Map 13 [SIMPLE_EDGE]
+                                 |              |  Reduce Output Operator [RS_36]
+                                 |              |     key expressions:_col0 (type: string)
+                                 |              |     Map-reduce partition columns:_col0 (type: string)
+                                 |              |     sort order:+
+                                 |              |     Statistics:Num rows: 125 Data size: 1328 Basic stats: COMPLETE Column stats: NONE
+                                 |              |     Select Operator [SEL_22]
+                                 |              |        outputColumnNames:["_col0"]
+                                 |              |        Statistics:Num rows: 125 Data size: 1328 Basic stats: COMPLETE Column stats: NONE
+                                 |              |        Filter Operator [FIL_102]
+                                 |              |           predicate:((value = 'd1value') and key is not null) (type: boolean)
+                                 |              |           Statistics:Num rows: 125 Data size: 1328 Basic stats: COMPLETE Column stats: NONE
+                                 |              |           TableScan [TS_20]
+                                 |              |              alias:d1
+                                 |              |              Statistics:Num rows: 500 Data size: 5312 Basic stats: COMPLETE Column stats: NONE
+                                 |              |<-Reducer 16 [SIMPLE_EDGE]
+                                 |                 Reduce Output Operator [RS_38]
+                                 |                    key expressions:_col2 (type: string)
+                                 |                    Map-reduce partition columns:_col2 (type: string)
+                                 |                    sort order:+
+                                 |                    Statistics:Num rows: 550 Data size: 5843 Basic stats: COMPLETE Column stats: NONE
+                                 |                    value expressions:_col3 (type: string), _col4 (type: string), _col6 (type: string)
+                                 |                    Merge Join Operator [MERGEJOIN_107]
+                                 |                    |  condition map:[{"":"Inner Join 0 to 1"}]
+                                 |                    |  keys:{"1":"_col3 (type: string)","0":"_col1 (type: string)"}
+                                 |                    |  outputColumnNames:["_col2","_col3","_col4","_col6"]
+                                 |                    |  Statistics:Num rows: 550 Data size: 5843 Basic stats: COMPLETE Column stats: NONE
+                                 |                    |<-Map 15 [SIMPLE_EDGE]
+                                 |                    |  Reduce Output Operator [RS_30]
+                                 |                    |     key expressions:_col1 (type: string)
+                                 |                    |     Map-reduce partition columns:_col1 (type: string)
+                                 |                    |     sort order:+
+                                 |                    |     Statistics:Num rows: 500 Data size: 5312 Basic stats: COMPLETE Column stats: NONE
+                                 |                    |     Select Operator [SEL_25]
+                                 |                    |        outputColumnNames:["_col1"]
+                                 |                    |        Statistics:Num rows: 500 Data size: 5312 Basic stats: COMPLETE Column stats: NONE
+                                 |                    |        Filter Operator [FIL_103]
+                                 |                    |           predicate:((key = 'srcpartkey') and value is not null) (type: boolean)
+                                 |                    |           Statistics:Num rows: 500 Data size: 5312 Basic stats: COMPLETE Column stats: NONE
+                                 |                    |           TableScan [TS_23]
+                                 |                    |              alias:srcpart
+                                 |                    |              Statistics:Num rows: 2000 Data size: 21248 Basic stats: COMPLETE Column stats: NONE
+                                 |                    |<-Map 17 [SIMPLE_EDGE]
+                                 |                       Reduce Output Operator [RS_32]
+                                 |                          key expressions:_col3 (type: string)
+                                 |                          Map-reduce partition columns:_col3 (type: string)
+                                 |                          sort order:+
+                                 |                          Statistics:Num rows: 2 Data size: 69 Basic stats: COMPLETE Column stats: NONE
+                                 |                          value expressions:_col0 (type: string), _col1 (type: string), _col2 (type: string), _col4 (type: string)
+                                 |                          Select Operator [SEL_28]
+                                 |                             outputColumnNames:["_col0","_col1","_col2","_col3","_col4"]
+                                 |                             Statistics:Num rows: 2 Data size: 69 Basic stats: COMPLETE Column stats: NONE
+                                 |                             Filter Operator [FIL_104]
+                                 |                                predicate:((((((v3 = 'ssv3') and v2 is not null) and k1 is not null) and v1 is not null) and k2 is not null) and k3 is not null) (type: boolean)
+                                 |                                Statistics:Num rows: 2 Data size: 69 Basic stats: COMPLETE Column stats: NONE
+                                 |                                TableScan [TS_26]
+                                 |                                   alias:ss
+                                 |                                   Statistics:Num rows: 85 Data size: 2945 Basic stats: COMPLETE Column stats: NONE
+                                 |<-Reducer 3 [SIMPLE_EDGE]
+                                    Reduce Output Operator [RS_58]
+                                       key expressions:_col8 (type: string), _col10 (type: string)
+                                       Map-reduce partition columns:_col8 (type: string), _col10 (type: string)
                                        sort order:++
-                                       Statistics:Num rows: 731 Data size: 7775 Basic stats: COMPLETE Column stats: NONE
-                                       value expressions:_col6 (type: string), _col7 (type: string), _col14 (type: string)
-                                       Select Operator [SEL_51]
-                                          outputColumnNames:["_col14","_col15","_col17","_col6","_col7"]
-                                          Statistics:Num rows: 731 Data size: 7775 Basic stats: COMPLETE Column stats: NONE
-                                          Merge Join Operator [MERGEJOIN_112]
-                                          |  condition map:[{"":"Inner Join 0 to 1"}]
-                                          |  keys:{"1":"_col2 (type: string), _col4 (type: string)","0":"_col8 (type: string), _col10 (type: string)"}
-                                          |  outputColumnNames:["_col6","_col7","_col14","_col15","_col17"]
-                                          |  Statistics:Num rows: 731 Data size: 7775 Basic stats: COMPLETE Column stats: NONE
-                                          |<-Reducer 16 [SIMPLE_EDGE]
-                                          |  Reduce Output Operator [RS_49]
-                                          |     key expressions:_col2 (type: string), _col4 (type: string)
-                                          |     Map-reduce partition columns:_col2 (type: string), _col4 (type: string)
-                                          |     sort order:++
-                                          |     Statistics:Num rows: 137 Data size: 1460 Basic stats: COMPLETE Column stats: NONE
-                                          |     value expressions:_col3 (type: string), _col5 (type: string)
-                                          |     Merge Join Operator [MERGEJOIN_111]
-                                          |     |  condition map:[{"":"Inner Join 0 to 1"}]
-                                          |     |  keys:{"1":"_col0 (type: string)","0":"_col0 (type: string)"}
-                                          |     |  outputColumnNames:["_col2","_col3","_col4","_col5"]
-                                          |     |  Statistics:Num rows: 137 Data size: 1460 Basic stats: COMPLETE Column stats: NONE
-                                          |     |<-Map 15 [SIMPLE_EDGE]
-                                          |     |  Reduce Output Operator [RS_36]
-                                          |     |     key expressions:_col0 (type: string)
-                                          |     |     Map-reduce partition columns:_col0 (type: string)
-                                          |     |     sort order:+
-                                          |     |     Statistics:Num rows: 2 Data size: 69 Basic stats: COMPLETE Column stats: NONE
-                                          |     |     value expressions:_col2 (type: string), _col3 (type: string), _col4 (type: string), _col5 (type: string)
-                                          |     |     Select Operator [SEL_31]
-                                          |     |        outputColumnNames:["_col0","_col2","_col3","_col4","_col5"]
-                                          |     |        Statistics:Num rows: 2 Data size: 69 Basic stats: COMPLETE Column stats: NONE
-                                          |     |        Filter Operator [FIL_105]
-                                          |     |           predicate:((((((v1 = 'srv1') and k1 is not null) and k2 is not null) and k3 is not null) and v2 is not null) and v3 is not null) (type: boolean)
-                                          |     |           Statistics:Num rows: 2 Data size: 69 Basic stats: COMPLETE Column stats: NONE
-                                          |     |           TableScan [TS_29]
-                                          |     |              alias:sr
-                                          |     |              Statistics:Num rows: 85 Data size: 2945 Basic stats: COMPLETE Column stats: NONE
-                                          |     |<-Map 17 [SIMPLE_EDGE]
-                                          |        Reduce Output Operator [RS_38]
-                                          |           key expressions:_col0 (type: string)
-                                          |           Map-reduce partition columns:_col0 (type: string)
-                                          |           sort order:+
-                                          |           Statistics:Num rows: 125 Data size: 1328 Basic stats: COMPLETE Column stats: NONE
-                                          |           Select Operator [SEL_34]
-                                          |              outputColumnNames:["_col0"]
-                                          |              Statistics:Num rows: 125 Data size: 1328 Basic stats: COMPLETE Column stats: NONE
-                                          |              Filter Operator [FIL_106]
-                                          |                 predicate:((value) IN ('2000Q1', '2000Q2', '2000Q3') and key is not null) (type: boolean)
-                                          |                 Statistics:Num rows: 125 Data size: 1328 Basic stats: COMPLETE Column stats: NONE
-                                          |                 TableScan [TS_32]
-                                          |                    alias:d1
-                                          |                    Statistics:Num rows: 500 Data size: 5312 Basic stats: COMPLETE Column stats: NONE
-                                          |<-Reducer 8 [SIMPLE_EDGE]
-                                             Reduce Output Operator [RS_47]
-                                                key expressions:_col8 (type: string), _col10 (type: string)
-                                                Map-reduce partition columns:_col8 (type: string), _col10 (type: string)
-                                                sort order:++
-                                                Statistics:Num rows: 665 Data size: 7069 Basic stats: COMPLETE Column stats: NONE
-                                                value expressions:_col6 (type: string), _col7 (type: string)
-                                                Merge Join Operator [MERGEJOIN_110]
-                                                |  condition map:[{"":"Inner Join 0 to 1"}]
-                                                |  keys:{"1":"_col5 (type: string)","0":"_col1 (type: string)"}
-                                                |  outputColumnNames:["_col6","_col7","_col8","_col10"]
-                                                |  Statistics:Num rows: 665 Data size: 7069 Basic stats: COMPLETE Column stats: NONE
-                                                |<-Map 7 [SIMPLE_EDGE]
-                                                |  Reduce Output Operator [RS_42]
-                                                |     key expressions:_col1 (type: string)
-                                                |     Map-reduce partition columns:_col1 (type: string)
-                                                |     sort order:+
-                                                |     Statistics:Num rows: 6 Data size: 45 Basic stats: COMPLETE Column stats: NONE
-                                                |     Select Operator [SEL_7]
-                                                |        outputColumnNames:["_col1"]
-                                                |        Statistics:Num rows: 6 Data size: 45 Basic stats: COMPLETE Column stats: NONE
-                                                |        Filter Operator [FIL_101]
-                                                |           predicate:((key = 'src1key') and value is not null) (type: boolean)
-                                                |           Statistics:Num rows: 6 Data size: 45 Basic stats: COMPLETE Column stats: NONE
-                                                |           TableScan [TS_5]
-                                                |              alias:src1
-                                                |              Statistics:Num rows: 25 Data size: 191 Basic stats: COMPLETE Column stats: NONE
-                                                |<-Reducer 11 [SIMPLE_EDGE]
-                                                   Reduce Output Operator [RS_44]
-                                                      key expressions:_col5 (type: string)
-                                                      Map-reduce partition columns:_col5 (type: string)
-                                                      sort order:+
-                                                      Statistics:Num rows: 605 Data size: 6427 Basic stats: COMPLETE Column stats: NONE
-                                                      value expressions:_col4 (type: string), _col6 (type: string), _col8 (type: string)
-                                                      Merge Join Operator [MERGEJOIN_109]
-                                                      |  condition map:[{"":"Inner Join 0 to 1"}]
-                                                      |  keys:{"1":"_col2 (type: string)","0":"_col0 (type: string)"}
-                                                      |  outputColumnNames:["_col4","_col5","_col6","_col8"]
-                                                      |  Statistics:Num rows: 605 Data size: 6427 Basic stats: COMPLETE Column stats: NONE
-                                                      |<-Map 10 [SIMPLE_EDGE]
-                                                      |  Reduce Output Operator [RS_24]
-                                                      |     key expressions:_col0 (type: string)
-                                                      |     Map-reduce partition columns:_col0 (type: string)
-                                                      |     sort order:+
-                                                      |     Statistics:Num rows: 125 Data size: 1328 Basic stats: COMPLETE Column stats: NONE
-                                                      |     Select Operator [SEL_10]
-                                                      |        outputColumnNames:["_col0"]
-                                                      |        Statistics:Num rows: 125 Data size: 1328 Basic stats: COMPLETE Column stats: NONE
-                                                      |        Filter Operator [FIL_102]
-                                                      |           predicate:((value = 'd1value') and key is not null) (type: boolean)
-                                                      |           Statistics:Num rows: 125 Data size: 1328 Basic stats: COMPLETE Column stats: NONE
-                                                      |           TableScan [TS_8]
-                                                      |              alias:d1
-                                                      |              Statistics:Num rows: 500 Data size: 5312 Basic stats: COMPLETE Column stats: NONE
-                                                      |<-Reducer 13 [SIMPLE_EDGE]
-                                                         Reduce Output Operator [RS_26]
-                                                            key expressions:_col2 (type: string)
-                                                            Map-reduce partition columns:_col2 (type: string)
-                                                            sort order:+
-                                                            Statistics:Num rows: 550 Data size: 5843 Basic stats: COMPLETE Column stats: NONE
-                                                            value expressions:_col3 (type: string), _col4 (type: string), _col6 (type: string)
-                                                            Merge Join Operator [MERGEJOIN_108]
-                                                            |  condition map:[{"":"Inner Join 0 to 1"}]
-                                                            |  keys:{"1":"_col3 (type: string)","0":"_col1 (type: string)"}
-                                                            |  outputColumnNames:["_col2","_col3","_col4","_col6"]
-                                                            |  Statistics:Num rows: 550 Data size: 5843 Basic stats: COMPLETE Column stats: NONE
-                                                            |<-Map 12 [SIMPLE_EDGE]
-                                                            |  Reduce Output Operator [RS_18]
-                                                            |     key expressions:_col1 (type: string)
-                                                            |     Map-reduce partition columns:_col1 (type: string)
-                                                            |     sort order:+
-                                                            |     Statistics:Num rows: 500 Data size: 5312 Basic stats: COMPLETE Column stats: NONE
-                                                            |     Select Operator [SEL_13]
-                                                            |        outputColumnNames:["_col1"]
-                                                            |        Statistics:Num rows: 500 Data size: 5312 Basic stats: COMPLETE Column stats: NONE
-                                                            |        Filter Operator [FIL_103]
-                                                            |           predicate:((key = 'srcpartkey') and value is not null) (type: boolean)
-                                                            |           Statistics:Num rows: 500 Data size: 5312 Basic stats: COMPLETE Column stats: NONE
-                                                            |           TableScan [TS_11]
-                                                            |              alias:srcpart
-                                                            |              Statistics:Num rows: 2000 Data size: 21248 Basic stats: COMPLETE Column stats: NONE
-                                                            |<-Map 14 [SIMPLE_EDGE]
-                                                               Reduce Output Operator [RS_20]
-                                                                  key expressions:_col3 (type: string)
-                                                                  Map-reduce partition columns:_col3 (type: string)
-                                                                  sort order:+
-                                                                  Statistics:Num rows: 2 Data size: 69 Basic stats: COMPLETE Column stats: NONE
-                                                                  value expressions:_col0 (type: string), _col1 (type: string), _col2 (type: string), _col4 (type: string)
-                                                                  Select Operator [SEL_16]
-                                                                     outputColumnNames:["_col0","_col1","_col2","_col3","_col4"]
-                                                                     Statistics:Num rows: 2 Data size: 69 Basic stats: COMPLETE Column stats: NONE
-                                                                     Filter Operator [FIL_104]
-                                                                        predicate:((((((v3 = 'ssv3') and v2 is not null) and k1 is not null) and v1 is not null) and k2 is not null) and k3 is not null) (type: boolean)
-                                                                        Statistics:Num rows: 2 Data size: 69 Basic stats: COMPLETE Column stats: NONE
-                                                                        TableScan [TS_14]
-                                                                           alias:ss
-                                                                           Statistics:Num rows: 85 Data size: 2945 Basic stats: COMPLETE Column stats: NONE
+                                       Statistics:Num rows: 150 Data size: 1606 Basic stats: COMPLETE Column stats: NONE
+                                       value expressions:_col2 (type: string), _col3 (type: string), _col9 (type: string)
+                                       Merge Join Operator [MERGEJOIN_110]
+                                       |  condition map:[{"":"Inner Join 0 to 1"}]
+                                       |  keys:{"1":"_col3 (type: string), _col5 (type: string)","0":"_col1 (type: string), _col3 (type: string)"}
+                                       |  outputColumnNames:["_col2","_col3","_col8","_col9","_col10"]
+                                       |  Statistics:Num rows: 150 Data size: 1606 Basic stats: COMPLETE Column stats: NONE
+                                       |<-Reducer 2 [SIMPLE_EDGE]
+                                       |  Reduce Output Operator [RS_53]
+                                       |     key expressions:_col1 (type: string), _col3 (type: string)
+                                       |     Map-reduce partition columns:_col1 (type: string), _col3 (type: string)
+                                       |     sort order:++
+                                       |     Statistics:Num rows: 137 Data size: 1460 Basic stats: COMPLETE Column stats: NONE
+                                       |     value expressions:_col2 (type: string)
+                                       |     Merge Join Operator [MERGEJOIN_105]
+                                       |     |  condition map:[{"":"Inner Join 0 to 1"}]
+                                       |     |  keys:{"1":"_col0 (type: string)","0":"_col0 (type: string)"}
+                                       |     |  outputColumnNames:["_col1","_col2","_col3"]
+                                       |     |  Statistics:Num rows: 137 Data size: 1460 Basic stats: COMPLETE Column stats: NONE
+                                       |     |<-Map 1 [SIMPLE_EDGE]
+                                       |     |  Reduce Output Operator [RS_48]
+                                       |     |     key expressions:_col0 (type: string)
+                                       |     |     Map-reduce partition columns:_col0 (type: string)
+                                       |     |     sort order:+
+                                       |     |     Statistics:Num rows: 22 Data size: 762 Basic stats: COMPLETE Column stats: NONE
+                                       |     |     value expressions:_col1 (type: string), _col2 (type: string), _col3 (type: string)
+                                       |     |     Select Operator [SEL_1]
+                                       |     |        outputColumnNames:["_col0","_col1","_col2","_col3"]
+                                       |     |        Statistics:Num rows: 22 Data size: 762 Basic stats: COMPLETE Column stats: NONE
+                                       |     |        Filter Operator [FIL_97]
+                                       |     |           predicate:((k1 is not null and v2 is not null) and v3 is not null) (type: boolean)
+                                       |     |           Statistics:Num rows: 22 Data size: 762 Basic stats: COMPLETE Column stats: NONE
+                                       |     |           TableScan [TS_0]
+                                       |     |              alias:cs
+                                       |     |              Statistics:Num rows: 170 Data size: 5890 Basic stats: COMPLETE Column stats: NONE
+                                       |     |<-Map 7 [SIMPLE_EDGE]
+                                       |        Reduce Output Operator [RS_50]
+                                       |           key expressions:_col0 (type: string)
+                                       |           Map-reduce partition columns:_col0 (type: string)
+                                       |           sort order:+
+                                       |           Statistics:Num rows: 125 Data size: 1328 Basic stats: COMPLETE Column stats: NONE
+                                       |           Select Operator [SEL_4]
+                                       |              outputColumnNames:["_col0"]
+                                       |              Statistics:Num rows: 125 Data size: 1328 Basic stats: COMPLETE Column stats: NONE
+                                       |              Filter Operator [FIL_98]
+                                       |                 predicate:((value) IN ('2000Q1', '2000Q2', '2000Q3') and key is not null) (type: boolean)
+                                       |                 Statistics:Num rows: 125 Data size: 1328 Basic stats: COMPLETE Column stats: NONE
+                                       |                 TableScan [TS_2]
+                                       |                    alias:d1
+                                       |                    Statistics:Num rows: 500 Data size: 5312 Basic stats: COMPLETE Column stats: NONE
+                                       |<-Reducer 9 [SIMPLE_EDGE]
+                                          Reduce Output Operator [RS_55]
+                                             key expressions:_col3 (type: string), _col5 (type: string)
+                                             Map-reduce partition columns:_col3 (type: string), _col5 (type: string)
+                                             sort order:++
+                                             Statistics:Num rows: 137 Data size: 1460 Basic stats: COMPLETE Column stats: NONE
+                                             value expressions:_col2 (type: string), _col4 (type: string)
+                                             Merge Join Operator [MERGEJOIN_106]
+                                             |  condition map:[{"":"Inner Join 0 to 1"}]
+                                             |  keys:{"1":"_col0 (type: string)","0":"_col0 (type: string)"}
+                                             |  outputColumnNames:["_col2","_col3","_col4","_col5"]
+                                             |  Statistics:Num rows: 137 Data size: 1460 Basic stats: COMPLETE Column stats: NONE
+                                             |<-Map 10 [SIMPLE_EDGE]
+                                             |  Reduce Output Operator [RS_14]
+                                             |     key expressions:_col0 (type: string)
+                                             |     Map-reduce partition columns:_col0 (type: string)
+                                             |     sort order:+
+                                             |     Statistics:Num rows: 125 Data size: 1328 Basic stats: COMPLETE Column stats: NONE
+                                             |     Select Operator [SEL_10]
+                                             |        outputColumnNames:["_col0"]
+                                             |        Statistics:Num rows: 125 Data size: 1328 Basic stats: COMPLETE Column stats: NONE
+                                             |        Filter Operator [FIL_100]
+                                             |           predicate:((value) IN ('2000Q1', '2000Q2', '2000Q3') and key is not null) (type: boolean)
+                                             |           Statistics:Num rows: 125 Data size: 1328 Basic stats: COMPLETE Column stats: NONE
+                                             |           TableScan [TS_8]
+                                             |              alias:d1
+                                             |              Statistics:Num rows: 500 Data size: 5312 Basic stats: COMPLETE Column stats: NONE
+                                             |<-Map 8 [SIMPLE_EDGE]
+                                                Reduce Output Operator [RS_12]
+                                                   key expressions:_col0 (type: string)
+                                                   Map-reduce partition columns:_col0 (type: string)
+                                                   sort order:+
+                                                   Statistics:Num rows: 2 Data size: 69 Basic stats: COMPLETE Column stats: NONE
+                                                   value expressions:_col2 (type: string), _col3 (type: string), _col4 (type: string), _col5 (type: string)
+                                                   Select Operator [SEL_7]
+                                                      outputColumnNames:["_col0","_col2","_col3","_col4","_col5"]
+                                                      Statistics:Num rows: 2 Data size: 69 Basic stats: COMPLETE Column stats: NONE
+                                                      Filter Operator [FIL_99]
+                                                         predicate:((((((v1 = 'srv1') and k1 is not null) and v2 is not null) and v3 is not null) and k2 is not null) and k3 is not null) (type: boolean)
+                                                         Statistics:Num rows: 2 Data size: 69 Basic stats: COMPLETE Column stats: NONE
+                                                         TableScan [TS_5]
+                                                            alias:sr
+                                                            Statistics:Num rows: 85 Data size: 2945 Basic stats: COMPLETE Column stats: NONE
 PREHOOK: query: explain
 SELECT x.key, z.value, y.value
 FROM src1 x JOIN src y ON (x.key = y.key) 
@@ -590,33 +590,33 @@ POSTHOOK: type: QUERY
 Plan optimized by CBO.
 
 Vertex dependency in root stage
-Reducer 13 <- Union 12 (SIMPLE_EDGE)
-Reducer 3 <- Union 2 (SIMPLE_EDGE)
-Reducer 14 <- Reducer 13 (SIMPLE_EDGE), Reducer 17 (SIMPLE_EDGE), Union 5 (CONTAINS)
-Map 11 <- Union 12 (CONTAINS)
-Map 1 <- Union 2 (CONTAINS)
-Reducer 4 <- Reducer 3 (SIMPLE_EDGE), Reducer 9 (SIMPLE_EDGE), Union 5 (CONTAINS)
-Map 7 <- Union 2 (CONTAINS)
-Reducer 6 <- Union 5 (SIMPLE_EDGE)
-Reducer 9 <- Map 10 (SIMPLE_EDGE), Map 8 (SIMPLE_EDGE)
-Reducer 17 <- Map 16 (SIMPLE_EDGE), Map 18 (SIMPLE_EDGE)
-Map 15 <- Union 12 (CONTAINS)
+Reducer 2 <- Map 1 (SIMPLE_EDGE), Reducer 8 (SIMPLE_EDGE), Union 3 (CONTAINS)
+Reducer 12 <- Map 11 (SIMPLE_EDGE), Reducer 16 (SIMPLE_EDGE), Union 3 (CONTAINS)
+Map 13 <- Union 14 (CONTAINS)
+Map 5 <- Union 6 (CONTAINS)
+Reducer 4 <- Union 3 (SIMPLE_EDGE)
+Reducer 7 <- Union 6 (SIMPLE_EDGE)
+Map 9 <- Union 6 (CONTAINS)
+Reducer 8 <- Map 10 (SIMPLE_EDGE), Reducer 7 (SIMPLE_EDGE)
+Reducer 15 <- Union 14 (SIMPLE_EDGE)
+Reducer 16 <- Map 18 (SIMPLE_EDGE), Reducer 15 (SIMPLE_EDGE)
+Map 17 <- Union 14 (CONTAINS)
 
 Stage-0
    Fetch Operator
       limit:-1
       Stage-1
-         Reducer 6
+         Reducer 4
          File Output Operator [FS_61]
             compressed:false
-            Statistics:Num rows: 302 Data size: 3213 Basic stats: COMPLETE Column stats: NONE
+            Statistics:Num rows: 275 Data size: 2921 Basic stats: COMPLETE Column stats: NONE
             table:{"serde:":"org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe","input format:":"org.apache.hadoop.mapred.TextInputFormat","output format:":"org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat"}
             Group By Operator [GBY_59]
             |  keys:KEY._col0 (type: string), KEY._col1 (type: string)
             |  outputColumnNames:["_col0","_col1"]
-            |  Statistics:Num rows: 302 Data size: 3213 Basic stats: COMPLETE Column stats: NONE
-            |<-Union 5 [SIMPLE_EDGE]
-               |<-Reducer 14 [CONTAINS]
+            |  Statistics:Num rows: 275 Data size: 2921 Basic stats: COMPLETE Column stats: NONE
+            |<-Union 3 [SIMPLE_EDGE]
+               |<-Reducer 2 [CONTAINS]
                |  Reduce Output Operator [RS_58]
                |     key expressions:_col0 (type: string), _col1 (type: string)
                |     Map-reduce partition columns:_col0 (type: string), _col1 (type: string)
@@ -624,98 +624,98 @@ Stage-0
                |     Group By Operator [GBY_57]
                |        keys:_col0 (type: string), _col1 (type: string)
                |        outputColumnNames:["_col0","_col1"]
-               |        Select Operator [SEL_53]
+               |        Select Operator [SEL_26]
                |           outputColumnNames:["_col0","_col1"]
                |           Merge Join Operator [MERGEJOIN_85]
                |           |  condition map:[{"":"Inner Join 0 to 1"}]
-               |           |  keys:{"1":"_col2 (type: string)","0":"_col0 (type: string)"}
-               |           |  outputColumnNames:["_col0","_col2"]
-               |           |<-Reducer 13 [SIMPLE_EDGE]
-               |           |  Reduce Output Operator [RS_49]
+               |           |  keys:{"1":"_col1 (type: string)","0":"_col0 (type: string)"}
+               |           |  outputColumnNames:["_col1","_col2"]
+               |           |<-Map 1 [SIMPLE_EDGE]
+               |           |  Reduce Output Operator [RS_22]
                |           |     key expressions:_col0 (type: string)
                |           |     Map-reduce partition columns:_col0 (type: string)
                |           |     sort order:+
-               |           |     Statistics:Num rows: 131 Data size: 1372 Basic stats: COMPLETE Column stats: NONE
-               |           |     Select Operator [SEL_37]
+               |           |     Statistics:Num rows: 250 Data size: 2656 Basic stats: COMPLETE Column stats: NONE
+               |           |     Select Operator [SEL_1]
                |           |        outputColumnNames:["_col0"]
-               |           |        Statistics:Num rows: 131 Data size: 1372 Basic stats: COMPLETE Column stats: NONE
-               |           |        Group By Operator [GBY_36]
-               |           |        |  keys:KEY._col0 (type: string), KEY._col1 (type: string)
-               |           |        |  outputColumnNames:["_col0","_col1"]
-               |           |        |  Statistics:Num rows: 131 Data size: 1372 Basic stats: COMPLETE Column stats: NONE
-               |           |        |<-Union 12 [SIMPLE_EDGE]
-               |           |           |<-Map 11 [CONTAINS]
-               |           |           |  Reduce Output Operator [RS_35]
-               |           |           |     key expressions:_col0 (type: string), _col1 (type: string)
-               |           |           |     Map-reduce partition columns:_col0 (type: string), _col1 (type: string)
-               |           |           |     sort order:++
-               |           |           |     Group By Operator [GBY_34]
-               |           |           |        keys:_col0 (type: string), _col1 (type: string)
-               |           |           |        outputColumnNames:["_col0","_col1"]
-               |           |           |        Select Operator [SEL_28]
-               |           |           |           outputColumnNames:["_col0","_col1"]
-               |           |           |           Filter Operator [FIL_78]
-               |           |           |              predicate:value is not null (type: boolean)
-               |           |           |              TableScan [TS_27]
-               |           |           |                 alias:x
-               |           |           |<-Map 15 [CONTAINS]
-               |           |              Reduce Output Operator [RS_35]
-               |           |                 key expressions:_col0 (type: string), _col1 (type: string)
-               |           |                 Map-reduce partition columns:_col0 (type: string), _col1 (type: string)
-               |           |                 sort order:++
-               |           |                 Group By Operator [GBY_34]
-               |           |                    keys:_col0 (type: string), _col1 (type: string)
-               |           |                    outputColumnNames:["_col0","_col1"]
-               |           |                    Select Operator [SEL_30]
-               |           |                       outputColumnNames:["_col0","_col1"]
-               |           |                       Filter Operator [FIL_79]
-               |           |                          predicate:value is not null (type: boolean)
-               |           |                          TableScan [TS_29]
-               |           |                             alias:y
-               |           |<-Reducer 17 [SIMPLE_EDGE]
-               |              Reduce Output Operator [RS_51]
-               |                 key expressions:_col2 (type: string)
-               |                 Map-reduce partition columns:_col2 (type: string)
+               |           |        Statistics:Num rows: 250 Data size: 2656 Basic stats: COMPLETE Column stats: NONE
+               |           |        Filter Operator [FIL_76]
+               |           |           predicate:key is not null (type: boolean)
+               |           |           Statistics:Num rows: 250 Data size: 2656 Basic stats: COMPLETE Column stats: NONE
+               |           |           TableScan [TS_0]
+               |           |              alias:y
+               |           |              Statistics:Num rows: 500 Data size: 5312 Basic stats: COMPLETE Column stats: NONE
+               |           |<-Reducer 8 [SIMPLE_EDGE]
+               |              Reduce Output Operator [RS_24]
+               |                 key expressions:_col1 (type: string)
+               |                 Map-reduce partition columns:_col1 (type: string)
                |                 sort order:+
-               |                 Statistics:Num rows: 275 Data size: 2921 Basic stats: COMPLETE Column stats: NONE
-               |                 value expressions:_col1 (type: string)
-               |                 Merge Join Operator [MERGEJOIN_83]
+               |                 Statistics:Num rows: 144 Data size: 1509 Basic stats: COMPLETE Column stats: NONE
+               |                 value expressions:_col0 (type: string)
+               |                 Merge Join Operator [MERGEJOIN_84]
                |                 |  condition map:[{"":"Inner Join 0 to 1"}]
-               |                 |  keys:{"1":"_col0 (type: string)","0":"_col0 (type: string)"}
-               |                 |  outputColumnNames:["_col1","_col2"]
-               |                 |  Statistics:Num rows: 275 Data size: 2921 Basic stats: COMPLETE Column stats: NONE
-               |                 |<-Map 16 [SIMPLE_EDGE]
-               |                 |  Reduce Output Operator [RS_43]
-               |                 |     key expressions:_col0 (type: string)
-               |                 |     Map-reduce partition columns:_col0 (type: string)
+               |                 |  keys:{"1":"_col1 (type: string)","0":"_col0 (type: string)"}
+               |                 |  outputColumnNames:["_col0","_col1"]
+               |                 |  Statistics:Num rows: 144 Data size: 1509 Basic stats: COMPLETE Column stats: NONE
+               |                 |<-Map 10 [SIMPLE_EDGE]
+               |                 |  Reduce Output Operator [RS_18]
+               |                 |     key expressions:_col1 (type: string)
+               |                 |     Map-reduce partition columns:_col1 (type: string)
                |                 |     sort order:+
-               |                 |     Statistics:Num rows: 250 Data size: 2656 Basic stats: COMPLETE Column stats: NONE
-               |                 |     Select Operator [SEL_39]
-               |                 |        outputColumnNames:["_col0"]
-               |                 |        Statistics:Num rows: 250 Data size: 2656 Basic stats: COMPLETE Column stats: NONE
-               |                 |        Filter Operator [FIL_80]
-               |                 |           predicate:key is not null (type: boolean)
-               |                 |           Statistics:Num rows: 250 Data size: 2656 Basic stats: COMPLETE Column stats: NONE
-               |                 |           TableScan [TS_38]
-               |                 |              alias:y
-               |                 |              Statistics:Num rows: 500 Data size: 5312 Basic stats: COMPLETE Column stats: NONE
-               |                 |<-Map 18 [SIMPLE_EDGE]
-               |                    Reduce Output Operator [RS_45]
+               |                 |     Statistics:Num rows: 7 Data size: 53 Basic stats: COMPLETE Column stats: NONE
+               |                 |     value expressions:_col0 (type: string)
+               |                 |     Select Operator [SEL_14]
+               |                 |        outputColumnNames:["_col0","_col1"]
+               |                 |        Statistics:Num rows: 7 Data size: 53 Basic stats: COMPLETE Column stats: NONE
+               |                 |        Filter Operator [FIL_79]
+               |                 |           predicate:(value is not null and key is not null) (type: boolean)
+               |                 |           Statistics:Num rows: 7 Data size: 53 Basic stats: COMPLETE Column stats: NONE
+               |                 |           TableScan [TS_13]
+               |                 |              alias:x
+               |                 |              Statistics:Num rows: 25 Data size: 191 Basic stats: COMPLETE Column stats: NONE
+               |                 |<-Reducer 7 [SIMPLE_EDGE]
+               |                    Reduce Output Operator [RS_16]
                |                       key expressions:_col0 (type: string)
                |                       Map-reduce partition columns:_col0 (type: string)
                |                       sort order:+
-               |                       Statistics:Num rows: 7 Data size: 53 Basic stats: COMPLETE Column stats: NONE
-               |                       value expressions:_col1 (type: string)
-               |                       Select Operator [SEL_41]
-               |                          outputColumnNames:["_col0","_col1"]
-               |                          Statistics:Num rows: 7 Data size: 53 Basic stats: COMPLETE Column stats: NONE
-               |                          Filter Operator [FIL_81]
-               |                             predicate:(key is not null and value is not null) (type: boolean)
-               |                             Statistics:Num rows: 7 Data size: 53 Basic stats: COMPLETE Column stats: NONE
-               |                             TableScan [TS_40]
-               |                                alias:x
-               |                                Statistics:Num rows: 25 Data size: 191 Basic stats: COMPLETE Column stats: NONE
-               |<-Reducer 4 [CONTAINS]
+               |                       Statistics:Num rows: 131 Data size: 1372 Basic stats: COMPLETE Column stats: NONE
+               |                       Select Operator [SEL_12]
+               |                          outputColumnNames:["_col0"]
+               |                          Statistics:Num rows: 131 Data size: 1372 Basic stats: COMPLETE Column stats: NONE
+               |                          Group By Operator [GBY_11]
+               |                          |  keys:KEY._col0 (type: string), KEY._col1 (type: string)
+               |                          |  outputColumnNames:["_col0","_col1"]
+               |                          |  Statistics:Num rows: 131 Data size: 1372 Basic stats: COMPLETE Column stats: NONE
+               |                          |<-Union 6 [SIMPLE_EDGE]
+               |                             |<-Map 5 [CONTAINS]
+               |                             |  Reduce Output Operator [RS_10]
+               |                             |     key expressions:_col0 (type: string), _col1 (type: string)
+               |                             |     Map-reduce partition columns:_col0 (type: string), _col1 (type: string)
+               |                             |     sort order:++
+               |                             |     Group By Operator [GBY_9]
+               |                             |        keys:_col0 (type: string), _col1 (type: string)
+               |                             |        outputColumnNames:["_col0","_col1"]
+               |                             |        Select Operator [SEL_3]
+               |                             |           outputColumnNames:["_col0","_col1"]
+               |                             |           Filter Operator [FIL_77]
+               |                             |              predicate:value is not null (type: boolean)
+               |                             |              TableScan [TS_2]
+               |                             |                 alias:x
+               |                             |<-Map 9 [CONTAINS]
+               |                                Reduce Output Operator [RS_10]
+               |                                   key expressions:_col0 (type: string), _col1 (type: string)
+               |                                   Map-reduce partition columns:_col0 (type: string), _col1 (type: string)
+               |                                   sort order:++
+               |                                   Group By Operator [GBY_9]
+               |                                      keys:_col0 (type: string), _col1 (type: string)
+               |                                      outputColumnNames:["_col0","_col1"]
+               |                                      Select Operator [SEL_5]
+               |                                         outputColumnNames:["_col0","_col1"]
+               |                                         Filter Operator [FIL_78]
+               |                                            predicate:value is not null (type: boolean)
+               |                                            TableScan [TS_4]
+               |                                               alias:y
+               |<-Reducer 12 [CONTAINS]
                   Reduce Output Operator [RS_58]
                      key expressions:_col0 (type: string), _col1 (type: string)
                      Map-reduce partition columns:_col0 (type: string), _col1 (type: string)
@@ -723,97 +723,97 @@ Stage-0
                      Group By Operator [GBY_57]
                         keys:_col0 (type: string), _col1 (type: string)
                         outputColumnNames:["_col0","_col1"]
-                        Select Operator [SEL_26]
+                        Select Operator [SEL_53]
                            outputColumnNames:["_col0","_col1"]
-                           Merge Join Operator [MERGEJOIN_84]
+                           Merge Join Operator [MERGEJOIN_87]
                            |  condition map:[{"":"Inner Join 0 to 1"}]
-                           |  keys:{"1":"_col2 (type: string)","0":"_col0 (type: string)"}
-                           |  outputColumnNames:["_col0","_col2"]
-                           |<-Reducer 3 [SIMPLE_EDGE]
-                           |  Reduce Output Operator [RS_22]
+                           |  keys:{"1":"_col1 (type: string)","0":"_col0 (type: string)"}
+                           |  outputColumnNames:["_col1","_col2"]
+                           |<-Map 11 [SIMPLE_EDGE]
+                           |  Reduce Output Operator [RS_49]
                            |     key expressions:_col0 (type: string)
                            |     Map-reduce partition columns:_col0 (type: string)
                            |     sort order:+
-                           |     Statistics:Num rows: 131 Data size: 1372 Basic stats: COMPLETE Column stats: NONE
-                           |     Select Operator [SEL_10]
+                           |     Statistics:Num rows: 250 Data size: 2656 Basic stats: COMPLETE Column stats: NONE
+                           |     Select Operator [SEL_28]
                            |        outputColumnNames:["_col0"]
-                           |        Statistics:Num rows: 131 Data size: 1372 Basic stats: COMPLETE Column stats: NONE
-                           |        Group By Operator [GBY_9]
-                           |        |  keys:KEY._col0 (type: string), KEY._col1 (type: string)
-                           |        |  outputColumnNames:["_col0","_col1"]
-                           |        |  Statistics:Num rows: 131 Data size: 1372 Basic stats: COMPLETE Column stats: NONE
-                           |        |<-Union 2 [SIMPLE_EDGE]
-                           |           |<-Map 1 [CONTAINS]
-                           |           |  Reduce Output Operator [RS_8]
-                           |           |     key expressions:_col0 (type: string), _col1 (type: string)
-                           |           |     Map-reduce partition columns:_col0 (type: string), _col1 (type: string)
-                           |           |     sort order:++
-                           |           |     Group By Operator [GBY_7]
-                           |           |        keys:_col0 (type: string), _col1 (type: string)
-                           |           |        outputColumnNames:["_col0","_col1"]
-                           |           |        Select Operator [SEL_1]
-                           |           |           outputColumnNames:["_col0","_col1"]
-                           |           |           Filter Operator [FIL_74]
-                           |           |              predicate:value is not null (type: boolean)
-                           |           |              TableScan [TS_0]
-                           |           |                 alias:x
-                           |           |<-Map 7 [CONTAINS]
-                           |              Reduce Output Operator [RS_8]
-                           |                 key expressions:_col0 (type: string), _col1 (type: string)
-                           |                 Map-reduce partition columns:_col0 (type: string), _col1 (type: string)
-                           |                 sort order:++
-                           |                 Group By Operator [GBY_7]
-                           |                    keys:_col0 (type: string), _col1 (type: string)
-                           |                    outputColumnNames:["_col0","_col1"]
-                           |                    Select Operator [SEL_3]
-                           |                       outputColumnNames:["_col0","_col1"]
-                           |                       Filter Operator [FIL_75]
-                           |                          predicate:value is not null (type: boolean)
-                           |                          TableScan [TS_2]
-                           |                             alias:y
-                           |<-Reducer 9 [SIMPLE_EDGE]
-                              Reduce Output Operator [RS_24]
-                                 key expressions:_col2 (type: string)
-                                 Map-reduce partition columns:_col2 (type: string)
+                           |        Statistics:Num rows: 250 Data size: 2656 Basic stats: COMPLETE Column stats: NONE
+                           |        Filter Operator [FIL_80]
+                           |           predicate:key is not null (type: boolean)
+                           |           Statistics:Num rows: 250 Data size: 2656 Basic stats: COMPLETE Column stats: NONE
+                           |           TableScan [TS_27]
+                           |              alias:y
+                           |              Statistics:Num rows: 500 Data size: 5312 Basic stats: COMPLETE Column stats: NONE
+                           |<-Reducer 16 [SIMPLE_EDGE]
+                              Reduce Output Operator [RS_51]
+                                 key expressions:_col1 (type: string)
+                                 Map-reduce partition columns:_col1 (type: string)
                                  sort order:+
-                                 Statistics:Num rows: 275 Data size: 2921 Basic stats: COMPLETE Column stats: NONE
-                                 value expressions:_col1 (type: string)
-                                 Merge Join Operator [MERGEJOIN_82]
+                                 Statistics:Num rows: 144 Data size: 1509 Basic stats: COMPLETE Column stats: NONE
+                                 value expressions:_col0 (type: string)
+                                 Merge Join Operator [MERGEJOIN_86]
                                  |  condition map:[{"":"Inner Join 0 to 1"}]
-                                 |  keys:{"1":"_col0 (type: string)","0":"_col0 (type: string)"}
-                                 |  outputColumnNames:["_col1","_col2"]
-                                 |  Statistics:Num rows: 275 Data size: 2921 Basic stats: COMPLETE Column stats: NONE
-                                 |<-Map 10 [SIMPLE_EDGE]
-                                 |  Reduce Output Operator [RS_18]
-                                 |     key expressions:_col0 (type: string)
-                                 |     Map-reduce partition columns:_col0 (type: string)
+                                 |  keys:{"1":"_col1 (type: string)","0":"_col0 (type: string)"}
+                                 |  outputColumnNames:["_col0","_col1"]
+                                 |  Statistics:Num rows: 144 Data size: 1509 Basic stats: COMPLETE Column stats: NONE
+                                 |<-Map 18 [SIMPLE_EDGE]
+                                 |  Reduce Output Operator [RS_45]
+                                 |     key expressions:_col1 (type: string)
+                                 |     Map-reduce partition columns:_col1 (type: string)
                                  |     sort order:+
                                  |     Statistics:Num rows: 7 Data size: 53 Basic stats: COMPLETE Column stats: NONE
-                                 |     value expressions:_col1 (type: string)
-                                 |     Select Operator [SEL_14]
+                                 |     value expressions:_col0 (type: string)
+                                 |     Select Operator [SEL_41]
                                  |        outputColumnNames:["_col0","_col1"]
                                  |        Statistics:Num rows: 7 Data size: 53 Basic stats: COMPLETE Column stats: NONE
-                                 |        Filter Operator [FIL_77]
-                                 |           predicate:(key is not null and value is not null) (type: boolean)
+                                 |        Filter Operator [FIL_83]
+                                 |           predicate:(value is not null and key is not null) (type: boolean)
                                  |           Statistics:Num rows: 7 Data size: 53 Basic stats: COMPLETE Column stats: NONE
-                                 |           TableScan [TS_13]
+                                 |           TableScan [TS_40]
                                  |              alias:x
                                  |              Statistics:Num rows: 25 Data size: 191 Basic stats: COMPLETE Column stats: NONE
-                                 |<-Map 8 [SIMPLE_EDGE]
-                                    Reduce Output Operator [RS_16]
+                                 |<-Reducer 15 [SIMPLE_EDGE]
+                                    Reduce Output Operator [RS_43]
                                        key expressions:_col0 (type: string)
                                        Map-reduce partition columns:_col0 (type: string)
                                        sort order:+
-                                       Statistics:Num rows: 250 Data size: 2656 Basic stats: COMPLETE Column stats: NONE
-                                       Select Operator [SEL_12]
+                                       Statistics:Num rows: 131 Data size: 1372 Basic stats: COMPLETE Column stats: NONE
+                                       Select Operator [SEL_39]
                                           outputColumnNames:["_col0"]
-                                          Statistics:Num rows: 250 Data size: 2656 Basic stats: COMPLETE Column stats: NONE
-                                          Filter Operator [FIL_76]
-                                             predicate:key is not null (type: boolean)
-                                             Statistics:Num rows: 250 Data size: 2656 Basic stats: COMPLETE Column stats: NONE
-                                             TableScan [TS_11]
-                                                alias:y
-                                                Statistics:Num rows: 500 Data size: 5312 Basic stats: COMPLETE Column stats: NONE
+                                          Statistics:Num rows: 131 Data size: 1372 Basic stats: COMPLETE Column stats: NONE
+                                          Group By Operator [GBY_38]
+                                          |  keys:KEY._col0 (type: string), KEY._col1 (type: string)
+                                          |  outputColumnNames:["_col0","_col1"]
+                                          |  Statistics:Num rows: 131 Data size: 1372 Basic stats: COMPLETE Column stats: NONE
+                                          |<-Union 14 [SIMPLE_EDGE]
+                                             |<-Map 13 [CONTAINS]
+                                             |  Reduce Output Operator [RS_37]
+                                             |     key expressions:_col0 (type: string), _col1 (type: string)
+                                             |     Map-reduce partition columns:_col0 (type: string), _col1 (type: string)
+                                             |     sort order:++
+                                             |     Group By Operator [GBY_36]
+                                             |        keys:_col0 (type: string), _col1 (type: string)
+                                             |        outputColumnNames:["_col0","_col1"]
+                                             |        Select Operator [SEL_30]
+                                             |           outputColumnNames:["_col0","_col1"]
+                                             |           Filter Operator [FIL_81]
+                                             |              predicate:value is not null (type: boolean)
+                                             |              TableScan [TS_29]
+                                             |                 alias:x
+                                             |<-Map 17 [CONTAINS]
+                                                Reduce Output Operator [RS_37]
+                                                   key expressions:_col0 (type: string), _col1 (type: string)
+                                                   Map-reduce partition columns:_col0 (type: string), _col1 (type: string)
+                                                   sort order:++
+                                                   Group By Operator [GBY_36]
+                                                      keys:_col0 (type: string), _col1 (type: string)
+                                                      outputColumnNames:["_col0","_col1"]
+                                                      Select Operator [SEL_32]
+                                                         outputColumnNames:["_col0","_col1"]
+                                                         Filter Operator [FIL_82]
+                                                            predicate:value is not null (type: boolean)
+                                                            TableScan [TS_31]
+                                                               alias:y
 PREHOOK: query: explain
 SELECT x.key, y.value
 FROM src1 x JOIN src y ON (x.key = y.key) 
@@ -843,45 +843,45 @@ POSTHOOK: type: QUERY
 Plan optimized by CBO.
 
 Vertex dependency in root stage
-Reducer 31 <- Reducer 30 (SIMPLE_EDGE), Reducer 36 (SIMPLE_EDGE), Union 7 (CONTAINS)
-Reducer 22 <- Map 21 (SIMPLE_EDGE), Map 23 (SIMPLE_EDGE)
-Map 24 <- Union 25 (CONTAINS)
-Map 32 <- Union 25 (CONTAINS)
-Reducer 11 <- Map 10 (SIMPLE_EDGE), Map 12 (SIMPLE_EDGE)
-Reducer 30 <- Union 29 (SIMPLE_EDGE)
-Map 13 <- Union 14 (CONTAINS)
-Map 34 <- Union 29 (CONTAINS)
-Reducer 36 <- Map 35 (SIMPLE_EDGE), Map 37 (SIMPLE_EDGE)
-Map 1 <- Union 2 (CONTAINS)
-Map 20 <- Union 16 (CONTAINS)
-Map 33 <- Union 27 (CONTAINS)
-Reducer 4 <- Reducer 11 (SIMPLE_EDGE), Reducer 3 (SIMPLE_EDGE), Union 5 (CONTAINS)
-Map 19 <- Union 14 (CONTAINS)
-Reducer 6 <- Union 5 (SIMPLE_EDGE), Union 7 (CONTAINS)
-Reducer 26 <- Union 25 (SIMPLE_EDGE), Union 27 (CONTAINS)
-Reducer 17 <- Union 16 (SIMPLE_EDGE)
-Reducer 8 <- Union 7 (SIMPLE_EDGE)
-Reducer 18 <- Reducer 17 (SIMPLE_EDGE), Reducer 22 (SIMPLE_EDGE), Union 5 (CONTAINS)
+Reducer 32 <- Union 31 (SIMPLE_EDGE)
+Map 11 <- Union 8 (CONTAINS)
+Reducer 14 <- Map 13 (SIMPLE_EDGE), Reducer 20 (SIMPLE_EDGE), Union 3 (CONTAINS)
+Reducer 30 <- Union 29 (SIMPLE_EDGE), Union 31 (CONTAINS)
+Reducer 25 <- Map 24 (SIMPLE_EDGE), Reducer 33 (SIMPLE_EDGE), Union 5 (CONTAINS)
+Map 22 <- Union 18 (CONTAINS)
+Map 21 <- Union 16 (CONTAINS)
+Map 34 <- Union 27 (CONTAINS)
+Reducer 10 <- Map 12 (SIMPLE_EDGE), Reducer 9 (SIMPLE_EDGE)
+Reducer 33 <- Map 37 (SIMPLE_EDGE), Reducer 32 (SIMPLE_EDGE)
+Reducer 20 <- Map 23 (SIMPLE_EDGE), Reducer 19 (SIMPLE_EDGE)
+Map 36 <- Union 31 (CONTAINS)
+Map 35 <- Union 29 (CONTAINS)
+Reducer 4 <- Union 3 (SIMPLE_EDGE), Union 5 (CONTAINS)
+Reducer 19 <- Union 18 (SIMPLE_EDGE)
+Reducer 6 <- Union 5 (SIMPLE_EDGE)
+Reducer 9 <- Union 8 (SIMPLE_EDGE)
+Reducer 17 <- Union 16 (SIMPLE_EDGE), Union 18 (CONTAINS)
+Map 15 <- Union 16 (CONTAINS)
 Reducer 28 <- Union 27 (SIMPLE_EDGE), Union 29 (CONTAINS)
-Reducer 15 <- Union 14 (SIMPLE_EDGE), Union 16 (CONTAINS)
-Reducer 3 <- Union 2 (SIMPLE_EDGE)
-Map 9 <- Union 2 (CONTAINS)
+Map 26 <- Union 27 (CONTAINS)
+Reducer 2 <- Map 1 (SIMPLE_EDGE), Reducer 10 (SIMPLE_EDGE), Union 3 (CONTAINS)
+Map 7 <- Union 8 (CONTAINS)
 
 Stage-0
    Fetch Operator
       limit:-1
       Stage-1
-         Reducer 8
+         Reducer 6
          File Output Operator [FS_122]
             compressed:false
-            Statistics:Num rows: 302 Data size: 3213 Basic stats: COMPLETE Column stats: NONE
+            Statistics:Num rows: 275 Data size: 2921 Basic stats: COMPLETE Column stats: NONE
             table:{"serde:":"org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe","input format:":"org.apache.hadoop.mapred.TextInputFormat","output format:":"org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat"}
             Group By Operator [GBY_120]
             |  keys:KEY._col0 (type: string), KEY._col1 (type: string)
             |  outputColumnNames:["_col0","_col1"]
-            |  Statistics:Num rows: 302 Data size: 3213 Basic stats: COMPLETE Column stats: NONE
-            |<-Union 7 [SIMPLE_EDGE]
-               |<-Reducer 31 [CONTAINS]
+            |  Statistics:Num rows: 275 Data size: 2921 Basic stats: COMPLETE Column stats: NONE
+            |<-Union 5 [SIMPLE_EDGE]
+               |<-Reducer 25 [CONTAINS]
                |  Reduce Output Operator [RS_119]
                |     key expressions:_col0 (type: string), _col1 (type: string)
                |     Map-reduce partition columns:_col0 (type: string), _col1 (type: string)
@@ -891,149 +891,148 @@ Stage-0
                |        outputColumnNames:["_col0","_col1"]
                |        Select Operator [SEL_114]
                |           outputColumnNames:["_col0","_col1"]
-               |           Merge Join Operator [MERGEJOIN_164]
+               |           Merge Join Operator [MERGEJOIN_170]
                |           |  condition map:[{"":"Inner Join 0 to 1"}]
-               |           |  keys:{"1":"_col3 (type: string)","0":"_col0 (type: string)"}
-               |           |  outputColumnNames:["_col2","_col3"]
-               |           |<-Reducer 30 [SIMPLE_EDGE]
+               |           |  keys:{"1":"_col1 (type: string)","0":"_col0 (type: string)"}
+               |           |  outputColumnNames:["_col1","_col3"]
+               |           |<-Map 24 [SIMPLE_EDGE]
                |           |  Reduce Output Operator [RS_110]
                |           |     key expressions:_col0 (type: string)
                |           |     Map-reduce partition columns:_col0 (type: string)
                |           |     sort order:+

[... 3525 lines stripped ...]


Mime
View raw message