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