You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by px...@apache.org on 2017/04/26 17:43:07 UTC

hive git commit: HIVE-16540: dynamic_semijoin_user_level is failing on MiniLlap (Pengcheng Xiong)

Repository: hive
Updated Branches:
  refs/heads/master 17b1110fa -> 120271e92


HIVE-16540: dynamic_semijoin_user_level is failing on MiniLlap (Pengcheng Xiong)


Project: http://git-wip-us.apache.org/repos/asf/hive/repo
Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/120271e9
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/120271e9
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/120271e9

Branch: refs/heads/master
Commit: 120271e922f193a3e2b87895a6855b6c695a26d9
Parents: 17b1110
Author: Pengcheng Xiong <px...@hortonworks.com>
Authored: Wed Apr 26 10:42:50 2017 -0700
Committer: Pengcheng Xiong <px...@hortonworks.com>
Committed: Wed Apr 26 10:42:50 2017 -0700

----------------------------------------------------------------------
 .../llap/dynamic_semijoin_user_level.q.out      | 41 ++++++++------------
 1 file changed, 16 insertions(+), 25 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hive/blob/120271e9/ql/src/test/results/clientpositive/llap/dynamic_semijoin_user_level.q.out
----------------------------------------------------------------------
diff --git a/ql/src/test/results/clientpositive/llap/dynamic_semijoin_user_level.q.out b/ql/src/test/results/clientpositive/llap/dynamic_semijoin_user_level.q.out
index 614c4fd..b910df4 100644
--- a/ql/src/test/results/clientpositive/llap/dynamic_semijoin_user_level.q.out
+++ b/ql/src/test/results/clientpositive/llap/dynamic_semijoin_user_level.q.out
@@ -369,13 +369,12 @@ POSTHOOK: type: QUERY
 Plan optimized by CBO.
 
 Vertex dependency in root stage
-Map 1 <- Reducer 5 (BROADCAST_EDGE), Reducer 8 (BROADCAST_EDGE)
-Map 7 <- Reducer 6 (BROADCAST_EDGE)
-Reducer 2 <- Map 1 (SIMPLE_EDGE), Map 4 (SIMPLE_EDGE), Map 7 (SIMPLE_EDGE)
+Map 1 <- Reducer 5 (BROADCAST_EDGE), Reducer 7 (BROADCAST_EDGE)
+Map 6 <- Reducer 5 (BROADCAST_EDGE)
+Reducer 2 <- Map 1 (SIMPLE_EDGE), Map 4 (SIMPLE_EDGE), Map 6 (SIMPLE_EDGE)
 Reducer 3 <- Reducer 2 (CUSTOM_SIMPLE_EDGE)
 Reducer 5 <- Map 4 (CUSTOM_SIMPLE_EDGE)
-Reducer 6 <- Map 4 (CUSTOM_SIMPLE_EDGE)
-Reducer 8 <- Map 7 (CUSTOM_SIMPLE_EDGE)
+Reducer 7 <- Map 6 (CUSTOM_SIMPLE_EDGE)
 
 Stage-0
   Fetch Operator
@@ -389,7 +388,7 @@ Stage-0
           PARTITION_ONLY_SHUFFLE [RS_15]
             Group By Operator [GBY_14] (rows=1 width=8)
               Output:["_col0"],aggregations:["count()"]
-              Merge Join Operator [MERGEJOIN_58] (rows=320 width=8)
+              Merge Join Operator [MERGEJOIN_46] (rows=320 width=8)
                 Conds:RS_9._col0=RS_10._col0(Inner),RS_10._col0=RS_11._col0(Inner)
               <-Map 4 [SIMPLE_EDGE] llap
                 PARTITION_ONLY_SHUFFLE [RS_10]
@@ -400,7 +399,7 @@ Stage-0
                       predicate:key1 is not null
                       TableScan [TS_3] (rows=20 width=87)
                         default@srcpart_small,srcpart_small,Tbl:COMPLETE,Col:PARTIAL,Output:["key1"]
-              <-Map 7 [SIMPLE_EDGE] llap
+              <-Map 6 [SIMPLE_EDGE] llap
                 PARTITION_ONLY_SHUFFLE [RS_11]
                   PartitionCols:_col0
                   Select Operator [SEL_8] (rows=2000 width=87)
@@ -409,15 +408,15 @@ Stage-0
                       predicate:(key is not null and (key BETWEEN DynamicValue(RS_10_srcpart_small_key_min) AND DynamicValue(RS_10_srcpart_small_key_max) and in_bloom_filter(key, DynamicValue(RS_10_srcpart_small_key_bloom_filter))))
                       TableScan [TS_6] (rows=2000 width=87)
                         default@srcpart_date,srcpart_date,Tbl:COMPLETE,Col:COMPLETE,Output:["key"]
-                      <-Reducer 6 [BROADCAST_EDGE] llap
-                        BROADCAST [RS_57]
-                          Group By Operator [GBY_56] (rows=1 width=552)
+                      <-Reducer 5 [BROADCAST_EDGE] llap
+                        BROADCAST [RS_45]
+                          Group By Operator [GBY_31] (rows=1 width=552)
                             Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=32)"]
                           <-Map 4 [CUSTOM_SIMPLE_EDGE] llap
-                            PARTITION_ONLY_SHUFFLE [RS_55]
-                              Group By Operator [GBY_54] (rows=1 width=552)
+                            PARTITION_ONLY_SHUFFLE [RS_30]
+                              Group By Operator [GBY_29] (rows=1 width=552)
                                 Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=32)"]
-                                Select Operator [SEL_53] (rows=20 width=87)
+                                Select Operator [SEL_28] (rows=20 width=87)
                                   Output:["_col0"]
                                    Please refer to the previous Select Operator [SEL_5]
               <-Map 1 [SIMPLE_EDGE] llap
@@ -431,20 +430,12 @@ Stage-0
                         default@alltypesorc_int,alltypesorc_int,Tbl:COMPLETE,Col:COMPLETE,Output:["cstring"]
                       <-Reducer 5 [BROADCAST_EDGE] llap
                         BROADCAST [RS_32]
-                          Group By Operator [GBY_31] (rows=1 width=552)
-                            Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=32)"]
-                          <-Map 4 [CUSTOM_SIMPLE_EDGE] llap
-                            PARTITION_ONLY_SHUFFLE [RS_30]
-                              Group By Operator [GBY_29] (rows=1 width=552)
-                                Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=32)"]
-                                Select Operator [SEL_28] (rows=20 width=87)
-                                  Output:["_col0"]
-                                   Please refer to the previous Select Operator [SEL_5]
-                      <-Reducer 8 [BROADCAST_EDGE] llap
+                           Please refer to the previous Group By Operator [GBY_31]
+                      <-Reducer 7 [BROADCAST_EDGE] llap
                         BROADCAST [RS_37]
                           Group By Operator [GBY_36] (rows=1 width=552)
                             Output:["_col0","_col1","_col2"],aggregations:["min(VALUE._col0)","max(VALUE._col1)","bloom_filter(VALUE._col2, expectedEntries=410)"]
-                          <-Map 7 [CUSTOM_SIMPLE_EDGE] llap
+                          <-Map 6 [CUSTOM_SIMPLE_EDGE] llap
                             PARTITION_ONLY_SHUFFLE [RS_35]
                               Group By Operator [GBY_34] (rows=1 width=552)
                                 Output:["_col0","_col1","_col2"],aggregations:["min(_col0)","max(_col0)","bloom_filter(_col0, expectedEntries=410)"]
@@ -1441,7 +1432,7 @@ Stage-0
     Stage-1
       Map 1 llap
       File Output Operator [FS_15]
-        Map Join Operator [MAPJOIN_37] (rows=3314 width=185)
+        Map Join Operator [MAPJOIN_33] (rows=3314 width=185)
           Conds:SEL_2._col1=Union 3._col0(Inner),Output:["_col0","_col1","_col2"]
         <-Union 3 [BROADCAST_EDGE]
           <-Map 2 [CONTAINS] llap