This is an automated email from the ASF dual-hosted git repository. 924060929 pushed a commit to branch fe_local_shuffle_rebase in repository https://gitbox.apache.org/repos/asf/doris.git
commit 2f33acd155d2988db0f5ec7e3254be3127b34d5b Author: 924060929 <[email protected]> AuthorDate: Tue May 19 18:41:19 2026 +0800 [test](local shuffle) Drop stats-sensitive shape assertions from test_multilevel_join_agg_local_shuffle The local-shuffle FE planner inserts LocalExchange nodes after the Nereids physical plan stage, so `explain shape plan` output is independent of enable_local_shuffle_planner. When the on/off variants did differ, the diff was always driven by stats-sensitive rewrites (e.g. cost-based InferSetOperatorDistinct), not by the planner mode itself — meaning the shape check was effectively asserting stats stability across environments, which it cannot guarantee. Keep result-equality (qt_*_result_on / _result_off) and check_sql_equal between planner modes; drop the shape assertions and the 72 _shape_on blocks from the .out file. --- .../test_multilevel_join_agg_local_shuffle.out | 2050 -------------------- .../test_multilevel_join_agg_local_shuffle.groovy | 7 +- 2 files changed, 6 insertions(+), 2051 deletions(-) diff --git a/regression-test/data/query_p0/join/test_multilevel_join_agg_local_shuffle.out b/regression-test/data/query_p0/join/test_multilevel_join_agg_local_shuffle.out index 8ccf2921dfa..652df5e654d 100644 --- a/regression-test/data/query_p0/join/test_multilevel_join_agg_local_shuffle.out +++ b/regression-test/data/query_p0/join/test_multilevel_join_agg_local_shuffle.out @@ -1,33 +1,4 @@ -- This file is automatically generated. You should know what you did if you want to edit this --- !bucket_shuffle_broadcast_agg_stage_1_shape_on -- -PhysicalResultSink ---PhysicalQuickSort[MERGE_SORT] -----PhysicalDistribute[DistributionSpecGather] -------PhysicalQuickSort[LOCAL_SORT] ---------hashAgg[GLOBAL] -----------PhysicalDistribute[DistributionSpecHash] -------------hashAgg[LOCAL] ---------------PhysicalProject -----------------hashJoin[INNER_JOIN broadcast] hashCondition=((ab.k1 = d.k1)) otherCondition=() -------------------PhysicalProject ---------------------hashJoin[INNER_JOIN shuffle] hashCondition=((expr_cast(k1 as BIGINT) = c1.k1)) otherCondition=() -----------------------PhysicalProject -------------------------hashAgg[GLOBAL] ---------------------------PhysicalProject -----------------------------hashJoin[INNER_JOIN bucketShuffle] hashCondition=((a.k1 = b.k1)) otherCondition=() -------------------------------PhysicalProject ---------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_a(a)] -------------------------------PhysicalProject ---------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_b(b)] -----------------------PhysicalProject -------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_c] -------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_d(d)] - -Hint log: -Used: [shuffle]_1 [broadcast]_2 -UnUsed: -SyntaxError: - -- !bucket_shuffle_broadcast_agg_stage_1_result_on -- 1 52 11 10 2 9 7 20 @@ -40,35 +11,6 @@ SyntaxError: 3 8 8 30 4 10 9 40 --- !bucket_shuffle_broadcast_agg_stage_2_shape_on -- -PhysicalResultSink ---PhysicalQuickSort[MERGE_SORT] -----PhysicalDistribute[DistributionSpecGather] -------PhysicalQuickSort[LOCAL_SORT] ---------hashAgg[GLOBAL] -----------PhysicalDistribute[DistributionSpecHash] -------------hashAgg[LOCAL] ---------------PhysicalProject -----------------hashJoin[INNER_JOIN broadcast] hashCondition=((ab.k1 = d.k1)) otherCondition=() -------------------PhysicalProject ---------------------hashJoin[INNER_JOIN shuffle] hashCondition=((expr_cast(k1 as BIGINT) = c1.k1)) otherCondition=() -----------------------PhysicalProject -------------------------hashAgg[GLOBAL] ---------------------------PhysicalProject -----------------------------hashJoin[INNER_JOIN bucketShuffle] hashCondition=((a.k1 = b.k1)) otherCondition=() -------------------------------PhysicalProject ---------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_a(a)] -------------------------------PhysicalProject ---------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_b(b)] -----------------------PhysicalProject -------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_c] -------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_d(d)] - -Hint log: -Used: [shuffle]_1 [broadcast]_2 -UnUsed: -SyntaxError: - -- !bucket_shuffle_broadcast_agg_stage_2_result_on -- 1 52 11 10 2 9 7 20 @@ -81,35 +23,6 @@ SyntaxError: 3 8 8 30 4 10 9 40 --- !bucket_shuffle_broadcast_agg_stage_3_shape_on -- -PhysicalResultSink ---PhysicalQuickSort[MERGE_SORT] -----PhysicalDistribute[DistributionSpecGather] -------PhysicalQuickSort[LOCAL_SORT] ---------hashAgg[GLOBAL] -----------PhysicalDistribute[DistributionSpecHash] -------------hashAgg[LOCAL] ---------------PhysicalProject -----------------hashJoin[INNER_JOIN broadcast] hashCondition=((ab.k1 = d.k1)) otherCondition=() -------------------PhysicalProject ---------------------hashJoin[INNER_JOIN shuffle] hashCondition=((expr_cast(k1 as BIGINT) = c1.k1)) otherCondition=() -----------------------PhysicalProject -------------------------hashAgg[GLOBAL] ---------------------------PhysicalProject -----------------------------hashJoin[INNER_JOIN bucketShuffle] hashCondition=((a.k1 = b.k1)) otherCondition=() -------------------------------PhysicalProject ---------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_a(a)] -------------------------------PhysicalProject ---------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_b(b)] -----------------------PhysicalProject -------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_c] -------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_d(d)] - -Hint log: -Used: [shuffle]_1 [broadcast]_2 -UnUsed: -SyntaxError: - -- !bucket_shuffle_broadcast_agg_stage_3_result_on -- 1 52 11 10 2 9 7 20 @@ -122,32 +35,6 @@ SyntaxError: 3 8 8 30 4 10 9 40 --- !shuffle_broadcast_broadcast_agg_stage_1_shape_on -- -PhysicalResultSink ---PhysicalQuickSort[MERGE_SORT] -----PhysicalDistribute[DistributionSpecGather] -------PhysicalQuickSort[LOCAL_SORT] ---------hashAgg[GLOBAL] -----------PhysicalDistribute[DistributionSpecHash] -------------hashAgg[LOCAL] ---------------PhysicalProject -----------------hashJoin[INNER_JOIN broadcast] hashCondition=((a.k1 = d2.k1)) otherCondition=() -------------------PhysicalProject ---------------------hashJoin[INNER_JOIN broadcast] hashCondition=((a.k1 = d1.k1)) otherCondition=() -----------------------PhysicalProject -------------------------hashJoin[INNER_JOIN shuffle] hashCondition=((expr_cast(k1 as BIGINT) = c1.k1)) otherCondition=() ---------------------------PhysicalProject -----------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_a(a)] ---------------------------PhysicalProject -----------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_c] -----------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_d(d1)] -------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_d(d2)] - -Hint log: -Used: [shuffle]_1 [broadcast]_2 -UnUsed: -SyntaxError: - -- !shuffle_broadcast_broadcast_agg_stage_1_result_on -- 1 10 62 10 2 5 54 20 @@ -160,32 +47,6 @@ SyntaxError: 3 5 38 30 4 6 49 40 --- !shuffle_broadcast_broadcast_agg_stage_2_shape_on -- -PhysicalResultSink ---PhysicalQuickSort[MERGE_SORT] -----PhysicalDistribute[DistributionSpecGather] -------PhysicalQuickSort[LOCAL_SORT] ---------hashAgg[GLOBAL] -----------PhysicalDistribute[DistributionSpecHash] -------------hashAgg[LOCAL] ---------------PhysicalProject -----------------hashJoin[INNER_JOIN broadcast] hashCondition=((a.k1 = d2.k1)) otherCondition=() -------------------PhysicalProject ---------------------hashJoin[INNER_JOIN broadcast] hashCondition=((a.k1 = d1.k1)) otherCondition=() -----------------------PhysicalProject -------------------------hashJoin[INNER_JOIN shuffle] hashCondition=((expr_cast(k1 as BIGINT) = c1.k1)) otherCondition=() ---------------------------PhysicalProject -----------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_a(a)] ---------------------------PhysicalProject -----------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_c] -----------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_d(d1)] -------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_d(d2)] - -Hint log: -Used: [shuffle]_1 [broadcast]_2 -UnUsed: -SyntaxError: - -- !shuffle_broadcast_broadcast_agg_stage_2_result_on -- 1 10 62 10 2 5 54 20 @@ -198,32 +59,6 @@ SyntaxError: 3 5 38 30 4 6 49 40 --- !shuffle_broadcast_broadcast_agg_stage_3_shape_on -- -PhysicalResultSink ---PhysicalQuickSort[MERGE_SORT] -----PhysicalDistribute[DistributionSpecGather] -------PhysicalQuickSort[LOCAL_SORT] ---------hashAgg[GLOBAL] -----------PhysicalDistribute[DistributionSpecHash] -------------hashAgg[LOCAL] ---------------PhysicalProject -----------------hashJoin[INNER_JOIN broadcast] hashCondition=((a.k1 = d2.k1)) otherCondition=() -------------------PhysicalProject ---------------------hashJoin[INNER_JOIN broadcast] hashCondition=((a.k1 = d1.k1)) otherCondition=() -----------------------PhysicalProject -------------------------hashJoin[INNER_JOIN shuffle] hashCondition=((expr_cast(k1 as BIGINT) = c1.k1)) otherCondition=() ---------------------------PhysicalProject -----------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_a(a)] ---------------------------PhysicalProject -----------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_c] -----------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_d(d1)] -------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_d(d2)] - -Hint log: -Used: [shuffle]_1 [broadcast]_2 -UnUsed: -SyntaxError: - -- !shuffle_broadcast_broadcast_agg_stage_3_result_on -- 1 10 62 10 2 5 54 20 @@ -236,40 +71,6 @@ SyntaxError: 3 5 38 30 4 6 49 40 --- !bucket_broadcast_shuffle_agg_stage_1_shape_on -- -PhysicalResultSink ---PhysicalQuickSort[MERGE_SORT] -----PhysicalDistribute[DistributionSpecGather] -------PhysicalQuickSort[LOCAL_SORT] ---------hashAgg[GLOBAL] -----------PhysicalDistribute[DistributionSpecHash] -------------hashAgg[LOCAL] ---------------PhysicalProject -----------------hashJoin[INNER_JOIN shuffleBucket] hashCondition=((expr_cast(k1 as BIGINT) = c1.k1)) otherCondition=() -------------------PhysicalProject ---------------------hashAgg[GLOBAL] -----------------------PhysicalProject -------------------------hashJoin[INNER_JOIN broadcast] hashCondition=((ab.k1 = d.k1)) otherCondition=() ---------------------------hashAgg[GLOBAL] -----------------------------PhysicalProject -------------------------------hashJoin[INNER_JOIN bucketShuffle] hashCondition=((a.k1 = b.k1)) otherCondition=() ---------------------------------PhysicalProject -----------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_a(a)] ---------------------------------PhysicalProject -----------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_b(b)] ---------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_d(d)] -------------------PhysicalProject ---------------------hashAgg[GLOBAL] -----------------------PhysicalDistribute[DistributionSpecHash] -------------------------hashAgg[LOCAL] ---------------------------PhysicalProject -----------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_c] - -Hint log: -Used: [broadcast]_1 [shuffle]_2 -UnUsed: -SyntaxError: - -- !bucket_broadcast_shuffle_agg_stage_1_result_on -- 1 26 11 10 2 9 7 20 @@ -282,40 +83,6 @@ SyntaxError: 3 8 8 30 4 10 9 40 --- !bucket_broadcast_shuffle_agg_stage_2_shape_on -- -PhysicalResultSink ---PhysicalQuickSort[MERGE_SORT] -----PhysicalDistribute[DistributionSpecGather] -------PhysicalQuickSort[LOCAL_SORT] ---------hashAgg[GLOBAL] -----------PhysicalDistribute[DistributionSpecHash] -------------hashAgg[LOCAL] ---------------PhysicalProject -----------------hashJoin[INNER_JOIN shuffleBucket] hashCondition=((expr_cast(k1 as BIGINT) = c1.k1)) otherCondition=() -------------------PhysicalProject ---------------------hashAgg[GLOBAL] -----------------------PhysicalProject -------------------------hashJoin[INNER_JOIN broadcast] hashCondition=((ab.k1 = d.k1)) otherCondition=() ---------------------------hashAgg[GLOBAL] -----------------------------PhysicalProject -------------------------------hashJoin[INNER_JOIN bucketShuffle] hashCondition=((a.k1 = b.k1)) otherCondition=() ---------------------------------PhysicalProject -----------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_a(a)] ---------------------------------PhysicalProject -----------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_b(b)] ---------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_d(d)] -------------------PhysicalProject ---------------------hashAgg[GLOBAL] -----------------------PhysicalDistribute[DistributionSpecHash] -------------------------hashAgg[LOCAL] ---------------------------PhysicalProject -----------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_c] - -Hint log: -Used: [broadcast]_1 [shuffle]_2 -UnUsed: -SyntaxError: - -- !bucket_broadcast_shuffle_agg_stage_2_result_on -- 1 26 11 10 2 9 7 20 @@ -328,40 +95,6 @@ SyntaxError: 3 8 8 30 4 10 9 40 --- !bucket_broadcast_shuffle_agg_stage_3_shape_on -- -PhysicalResultSink ---PhysicalQuickSort[MERGE_SORT] -----PhysicalDistribute[DistributionSpecGather] -------PhysicalQuickSort[LOCAL_SORT] ---------hashAgg[GLOBAL] -----------PhysicalDistribute[DistributionSpecHash] -------------hashAgg[LOCAL] ---------------PhysicalProject -----------------hashJoin[INNER_JOIN shuffleBucket] hashCondition=((expr_cast(k1 as BIGINT) = c1.k1)) otherCondition=() -------------------PhysicalProject ---------------------hashAgg[GLOBAL] -----------------------PhysicalProject -------------------------hashJoin[INNER_JOIN broadcast] hashCondition=((ab.k1 = d.k1)) otherCondition=() ---------------------------hashAgg[GLOBAL] -----------------------------PhysicalProject -------------------------------hashJoin[INNER_JOIN bucketShuffle] hashCondition=((a.k1 = b.k1)) otherCondition=() ---------------------------------PhysicalProject -----------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_a(a)] ---------------------------------PhysicalProject -----------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_b(b)] ---------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_d(d)] -------------------PhysicalProject ---------------------hashAgg[GLOBAL] -----------------------PhysicalDistribute[DistributionSpecHash] -------------------------hashAgg[LOCAL] ---------------------------PhysicalProject -----------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_c] - -Hint log: -Used: [broadcast]_1 [shuffle]_2 -UnUsed: -SyntaxError: - -- !bucket_broadcast_shuffle_agg_stage_3_result_on -- 1 26 11 10 2 9 7 20 @@ -374,31 +107,6 @@ SyntaxError: 3 8 8 30 4 10 9 40 --- !alternating_bucket_bucket_bucket_shape_on -- -PhysicalResultSink ---PhysicalQuickSort[MERGE_SORT] -----PhysicalDistribute[DistributionSpecGather] -------PhysicalQuickSort[LOCAL_SORT] ---------hashAgg[GLOBAL] -----------PhysicalProject -------------hashJoin[INNER_JOIN bucketShuffle] hashCondition=((s2.k1 = d.k1)) otherCondition=() ---------------hashAgg[GLOBAL] -----------------PhysicalDistribute[DistributionSpecHash] -------------------hashAgg[LOCAL] ---------------------PhysicalProject -----------------------hashJoin[INNER_JOIN shuffle] hashCondition=((expr_cast(k1 as BIGINT) = c.k1)) otherCondition=() -------------------------PhysicalProject ---------------------------hashAgg[GLOBAL] -----------------------------PhysicalProject -------------------------------hashJoin[INNER_JOIN bucketShuffle] hashCondition=((a.k1 = b.k1)) otherCondition=() ---------------------------------PhysicalProject -----------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_a(a)] ---------------------------------PhysicalProject -----------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_b(b)] -------------------------PhysicalProject ---------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_c] ---------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_d(d)] - -- !alternating_bucket_bucket_bucket_result_on -- 1 63 16 11 2 16 24 22 @@ -411,36 +119,6 @@ PhysicalResultSink 3 16 35 33 4 19 46 44 --- !alternating_bucket_bucket_shuffle_shape_on -- -PhysicalResultSink ---PhysicalQuickSort[MERGE_SORT] -----PhysicalDistribute[DistributionSpecGather] -------PhysicalQuickSort[LOCAL_SORT] ---------hashAgg[GLOBAL] -----------PhysicalProject -------------hashJoin[INNER_JOIN bucketShuffle] hashCondition=((s2.k1 = d.k1)) otherCondition=() ---------------hashAgg[GLOBAL] -----------------PhysicalDistribute[DistributionSpecHash] -------------------hashAgg[LOCAL] ---------------------PhysicalProject -----------------------hashJoin[INNER_JOIN shuffle] hashCondition=((expr_cast(k1 as BIGINT) = c.k1)) otherCondition=() -------------------------PhysicalProject ---------------------------hashAgg[GLOBAL] -----------------------------PhysicalProject -------------------------------hashJoin[INNER_JOIN bucketShuffle] hashCondition=((a.k1 = b.k1)) otherCondition=() ---------------------------------PhysicalProject -----------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_a(a)] ---------------------------------PhysicalProject -----------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_b(b)] -------------------------PhysicalProject ---------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_c] ---------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_d(d)] - -Hint log: -Used: [shuffle]_1 -UnUsed: -SyntaxError: - -- !alternating_bucket_bucket_shuffle_result_on -- 1 63 16 11 2 16 24 22 @@ -453,36 +131,6 @@ SyntaxError: 3 16 35 33 4 19 46 44 --- !alternating_bucket_bucket_broadcast_shape_on -- -PhysicalResultSink ---PhysicalQuickSort[MERGE_SORT] -----PhysicalDistribute[DistributionSpecGather] -------PhysicalQuickSort[LOCAL_SORT] ---------hashAgg[GLOBAL] -----------PhysicalProject -------------hashJoin[INNER_JOIN broadcast] hashCondition=((s2.k1 = d.k1)) otherCondition=() ---------------hashAgg[GLOBAL] -----------------PhysicalDistribute[DistributionSpecHash] -------------------hashAgg[LOCAL] ---------------------PhysicalProject -----------------------hashJoin[INNER_JOIN shuffle] hashCondition=((expr_cast(k1 as BIGINT) = c.k1)) otherCondition=() -------------------------PhysicalProject ---------------------------hashAgg[GLOBAL] -----------------------------PhysicalProject -------------------------------hashJoin[INNER_JOIN bucketShuffle] hashCondition=((a.k1 = b.k1)) otherCondition=() ---------------------------------PhysicalProject -----------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_a(a)] ---------------------------------PhysicalProject -----------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_b(b)] -------------------------PhysicalProject ---------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_c] ---------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_d(d)] - -Hint log: -Used: [broadcast]_1 -UnUsed: -SyntaxError: - -- !alternating_bucket_bucket_broadcast_result_on -- 1 63 16 11 2 16 24 22 @@ -495,36 +143,6 @@ SyntaxError: 3 16 35 33 4 19 46 44 --- !alternating_bucket_shuffle_bucket_shape_on -- -PhysicalResultSink ---PhysicalQuickSort[MERGE_SORT] -----PhysicalDistribute[DistributionSpecGather] -------PhysicalQuickSort[LOCAL_SORT] ---------hashAgg[GLOBAL] -----------PhysicalProject -------------hashJoin[INNER_JOIN bucketShuffle] hashCondition=((s2.k1 = d.k1)) otherCondition=() ---------------hashAgg[GLOBAL] -----------------PhysicalDistribute[DistributionSpecHash] -------------------hashAgg[LOCAL] ---------------------PhysicalProject -----------------------hashJoin[INNER_JOIN shuffle] hashCondition=((expr_cast(k1 as BIGINT) = c.k1)) otherCondition=() -------------------------PhysicalProject ---------------------------hashAgg[GLOBAL] -----------------------------PhysicalProject -------------------------------hashJoin[INNER_JOIN bucketShuffle] hashCondition=((a.k1 = b.k1)) otherCondition=() ---------------------------------PhysicalProject -----------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_a(a)] ---------------------------------PhysicalProject -----------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_b(b)] -------------------------PhysicalProject ---------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_c] ---------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_d(d)] - -Hint log: -Used: [shuffle]_1 -UnUsed: -SyntaxError: - -- !alternating_bucket_shuffle_bucket_result_on -- 1 63 16 11 2 16 24 22 @@ -537,36 +155,6 @@ SyntaxError: 3 16 35 33 4 19 46 44 --- !alternating_bucket_shuffle_shuffle_shape_on -- -PhysicalResultSink ---PhysicalQuickSort[MERGE_SORT] -----PhysicalDistribute[DistributionSpecGather] -------PhysicalQuickSort[LOCAL_SORT] ---------hashAgg[GLOBAL] -----------PhysicalProject -------------hashJoin[INNER_JOIN bucketShuffle] hashCondition=((s2.k1 = d.k1)) otherCondition=() ---------------hashAgg[GLOBAL] -----------------PhysicalDistribute[DistributionSpecHash] -------------------hashAgg[LOCAL] ---------------------PhysicalProject -----------------------hashJoin[INNER_JOIN shuffle] hashCondition=((expr_cast(k1 as BIGINT) = c.k1)) otherCondition=() -------------------------PhysicalProject ---------------------------hashAgg[GLOBAL] -----------------------------PhysicalProject -------------------------------hashJoin[INNER_JOIN bucketShuffle] hashCondition=((a.k1 = b.k1)) otherCondition=() ---------------------------------PhysicalProject -----------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_a(a)] ---------------------------------PhysicalProject -----------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_b(b)] -------------------------PhysicalProject ---------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_c] ---------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_d(d)] - -Hint log: -Used: [shuffle]_1 -UnUsed: -SyntaxError: - -- !alternating_bucket_shuffle_shuffle_result_on -- 1 63 16 11 2 16 24 22 @@ -579,36 +167,6 @@ SyntaxError: 3 16 35 33 4 19 46 44 --- !alternating_bucket_shuffle_broadcast_shape_on -- -PhysicalResultSink ---PhysicalQuickSort[MERGE_SORT] -----PhysicalDistribute[DistributionSpecGather] -------PhysicalQuickSort[LOCAL_SORT] ---------hashAgg[GLOBAL] -----------PhysicalProject -------------hashJoin[INNER_JOIN broadcast] hashCondition=((s2.k1 = d.k1)) otherCondition=() ---------------hashAgg[GLOBAL] -----------------PhysicalDistribute[DistributionSpecHash] -------------------hashAgg[LOCAL] ---------------------PhysicalProject -----------------------hashJoin[INNER_JOIN shuffle] hashCondition=((expr_cast(k1 as BIGINT) = c.k1)) otherCondition=() -------------------------PhysicalProject ---------------------------hashAgg[GLOBAL] -----------------------------PhysicalProject -------------------------------hashJoin[INNER_JOIN bucketShuffle] hashCondition=((a.k1 = b.k1)) otherCondition=() ---------------------------------PhysicalProject -----------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_a(a)] ---------------------------------PhysicalProject -----------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_b(b)] -------------------------PhysicalProject ---------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_c] ---------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_d(d)] - -Hint log: -Used: [shuffle]_1 [broadcast]_2 -UnUsed: -SyntaxError: - -- !alternating_bucket_shuffle_broadcast_result_on -- 1 63 16 11 2 16 24 22 @@ -621,34 +179,6 @@ SyntaxError: 3 16 35 33 4 19 46 44 --- !alternating_bucket_broadcast_bucket_shape_on -- -PhysicalResultSink ---PhysicalQuickSort[MERGE_SORT] -----PhysicalDistribute[DistributionSpecGather] -------PhysicalQuickSort[LOCAL_SORT] ---------hashAgg[GLOBAL] -----------PhysicalProject -------------hashJoin[INNER_JOIN bucketShuffle] hashCondition=((s2.k1 = d.k1)) otherCondition=() ---------------hashAgg[GLOBAL] -----------------PhysicalProject -------------------hashJoin[INNER_JOIN broadcast] hashCondition=((expr_cast(k1 as BIGINT) = c.k1)) otherCondition=() ---------------------PhysicalProject -----------------------hashAgg[GLOBAL] -------------------------PhysicalProject ---------------------------hashJoin[INNER_JOIN bucketShuffle] hashCondition=((a.k1 = b.k1)) otherCondition=() -----------------------------PhysicalProject -------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_a(a)] -----------------------------PhysicalProject -------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_b(b)] ---------------------PhysicalProject -----------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_c] ---------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_d(d)] - -Hint log: -Used: [broadcast]_1 -UnUsed: -SyntaxError: - -- !alternating_bucket_broadcast_bucket_result_on -- 1 63 16 11 2 16 24 22 @@ -661,34 +191,6 @@ SyntaxError: 3 16 35 33 4 19 46 44 --- !alternating_bucket_broadcast_shuffle_shape_on -- -PhysicalResultSink ---PhysicalQuickSort[MERGE_SORT] -----PhysicalDistribute[DistributionSpecGather] -------PhysicalQuickSort[LOCAL_SORT] ---------hashAgg[GLOBAL] -----------PhysicalProject -------------hashJoin[INNER_JOIN bucketShuffle] hashCondition=((s2.k1 = d.k1)) otherCondition=() ---------------hashAgg[GLOBAL] -----------------PhysicalProject -------------------hashJoin[INNER_JOIN broadcast] hashCondition=((expr_cast(k1 as BIGINT) = c.k1)) otherCondition=() ---------------------PhysicalProject -----------------------hashAgg[GLOBAL] -------------------------PhysicalProject ---------------------------hashJoin[INNER_JOIN bucketShuffle] hashCondition=((a.k1 = b.k1)) otherCondition=() -----------------------------PhysicalProject -------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_a(a)] -----------------------------PhysicalProject -------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_b(b)] ---------------------PhysicalProject -----------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_c] ---------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_d(d)] - -Hint log: -Used: [broadcast]_1 [shuffle]_2 -UnUsed: -SyntaxError: - -- !alternating_bucket_broadcast_shuffle_result_on -- 1 63 16 11 2 16 24 22 @@ -701,34 +203,6 @@ SyntaxError: 3 16 35 33 4 19 46 44 --- !alternating_bucket_broadcast_broadcast_shape_on -- -PhysicalResultSink ---PhysicalQuickSort[MERGE_SORT] -----PhysicalDistribute[DistributionSpecGather] -------PhysicalQuickSort[LOCAL_SORT] ---------hashAgg[GLOBAL] -----------PhysicalProject -------------hashJoin[INNER_JOIN broadcast] hashCondition=((s2.k1 = d.k1)) otherCondition=() ---------------hashAgg[GLOBAL] -----------------PhysicalProject -------------------hashJoin[INNER_JOIN broadcast] hashCondition=((expr_cast(k1 as BIGINT) = c.k1)) otherCondition=() ---------------------PhysicalProject -----------------------hashAgg[GLOBAL] -------------------------PhysicalProject ---------------------------hashJoin[INNER_JOIN bucketShuffle] hashCondition=((a.k1 = b.k1)) otherCondition=() -----------------------------PhysicalProject -------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_a(a)] -----------------------------PhysicalProject -------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_b(b)] ---------------------PhysicalProject -----------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_c] ---------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_d(d)] - -Hint log: -Used: [broadcast]_1 -UnUsed: -SyntaxError: - -- !alternating_bucket_broadcast_broadcast_result_on -- 1 63 16 11 2 16 24 22 @@ -741,36 +215,6 @@ SyntaxError: 3 16 35 33 4 19 46 44 --- !alternating_shuffle_bucket_bucket_shape_on -- -PhysicalResultSink ---PhysicalQuickSort[MERGE_SORT] -----PhysicalDistribute[DistributionSpecGather] -------PhysicalQuickSort[LOCAL_SORT] ---------hashAgg[GLOBAL] -----------PhysicalProject -------------hashJoin[INNER_JOIN bucketShuffle] hashCondition=((s2.k1 = d.k1)) otherCondition=() ---------------hashAgg[GLOBAL] -----------------PhysicalDistribute[DistributionSpecHash] -------------------hashAgg[LOCAL] ---------------------PhysicalProject -----------------------hashJoin[INNER_JOIN shuffle] hashCondition=((expr_cast(k1 as BIGINT) = c.k1)) otherCondition=() -------------------------PhysicalProject ---------------------------hashAgg[GLOBAL] -----------------------------PhysicalProject -------------------------------hashJoin[INNER_JOIN bucketShuffle] hashCondition=((a.k1 = b.k1)) otherCondition=() ---------------------------------PhysicalProject -----------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_a(a)] ---------------------------------PhysicalProject -----------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_b(b)] -------------------------PhysicalProject ---------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_c] ---------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_d(d)] - -Hint log: -Used: [shuffle]_1 -UnUsed: -SyntaxError: - -- !alternating_shuffle_bucket_bucket_result_on -- 1 63 16 11 2 16 24 22 @@ -783,36 +227,6 @@ SyntaxError: 3 16 35 33 4 19 46 44 --- !alternating_shuffle_bucket_shuffle_shape_on -- -PhysicalResultSink ---PhysicalQuickSort[MERGE_SORT] -----PhysicalDistribute[DistributionSpecGather] -------PhysicalQuickSort[LOCAL_SORT] ---------hashAgg[GLOBAL] -----------PhysicalProject -------------hashJoin[INNER_JOIN bucketShuffle] hashCondition=((s2.k1 = d.k1)) otherCondition=() ---------------hashAgg[GLOBAL] -----------------PhysicalDistribute[DistributionSpecHash] -------------------hashAgg[LOCAL] ---------------------PhysicalProject -----------------------hashJoin[INNER_JOIN shuffle] hashCondition=((expr_cast(k1 as BIGINT) = c.k1)) otherCondition=() -------------------------PhysicalProject ---------------------------hashAgg[GLOBAL] -----------------------------PhysicalProject -------------------------------hashJoin[INNER_JOIN bucketShuffle] hashCondition=((a.k1 = b.k1)) otherCondition=() ---------------------------------PhysicalProject -----------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_a(a)] ---------------------------------PhysicalProject -----------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_b(b)] -------------------------PhysicalProject ---------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_c] ---------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_d(d)] - -Hint log: -Used: [shuffle]_1 -UnUsed: -SyntaxError: - -- !alternating_shuffle_bucket_shuffle_result_on -- 1 63 16 11 2 16 24 22 @@ -825,36 +239,6 @@ SyntaxError: 3 16 35 33 4 19 46 44 --- !alternating_shuffle_bucket_broadcast_shape_on -- -PhysicalResultSink ---PhysicalQuickSort[MERGE_SORT] -----PhysicalDistribute[DistributionSpecGather] -------PhysicalQuickSort[LOCAL_SORT] ---------hashAgg[GLOBAL] -----------PhysicalProject -------------hashJoin[INNER_JOIN broadcast] hashCondition=((s2.k1 = d.k1)) otherCondition=() ---------------hashAgg[GLOBAL] -----------------PhysicalDistribute[DistributionSpecHash] -------------------hashAgg[LOCAL] ---------------------PhysicalProject -----------------------hashJoin[INNER_JOIN shuffle] hashCondition=((expr_cast(k1 as BIGINT) = c.k1)) otherCondition=() -------------------------PhysicalProject ---------------------------hashAgg[GLOBAL] -----------------------------PhysicalProject -------------------------------hashJoin[INNER_JOIN bucketShuffle] hashCondition=((a.k1 = b.k1)) otherCondition=() ---------------------------------PhysicalProject -----------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_a(a)] ---------------------------------PhysicalProject -----------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_b(b)] -------------------------PhysicalProject ---------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_c] ---------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_d(d)] - -Hint log: -Used: [shuffle]_1 [broadcast]_2 -UnUsed: -SyntaxError: - -- !alternating_shuffle_bucket_broadcast_result_on -- 1 63 16 11 2 16 24 22 @@ -867,36 +251,6 @@ SyntaxError: 3 16 35 33 4 19 46 44 --- !alternating_shuffle_shuffle_bucket_shape_on -- -PhysicalResultSink ---PhysicalQuickSort[MERGE_SORT] -----PhysicalDistribute[DistributionSpecGather] -------PhysicalQuickSort[LOCAL_SORT] ---------hashAgg[GLOBAL] -----------PhysicalProject -------------hashJoin[INNER_JOIN bucketShuffle] hashCondition=((s2.k1 = d.k1)) otherCondition=() ---------------hashAgg[GLOBAL] -----------------PhysicalDistribute[DistributionSpecHash] -------------------hashAgg[LOCAL] ---------------------PhysicalProject -----------------------hashJoin[INNER_JOIN shuffle] hashCondition=((expr_cast(k1 as BIGINT) = c.k1)) otherCondition=() -------------------------PhysicalProject ---------------------------hashAgg[GLOBAL] -----------------------------PhysicalProject -------------------------------hashJoin[INNER_JOIN bucketShuffle] hashCondition=((a.k1 = b.k1)) otherCondition=() ---------------------------------PhysicalProject -----------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_a(a)] ---------------------------------PhysicalProject -----------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_b(b)] -------------------------PhysicalProject ---------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_c] ---------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_d(d)] - -Hint log: -Used: [shuffle]_1 -UnUsed: -SyntaxError: - -- !alternating_shuffle_shuffle_bucket_result_on -- 1 63 16 11 2 16 24 22 @@ -909,36 +263,6 @@ SyntaxError: 3 16 35 33 4 19 46 44 --- !alternating_shuffle_shuffle_shuffle_shape_on -- -PhysicalResultSink ---PhysicalQuickSort[MERGE_SORT] -----PhysicalDistribute[DistributionSpecGather] -------PhysicalQuickSort[LOCAL_SORT] ---------hashAgg[GLOBAL] -----------PhysicalProject -------------hashJoin[INNER_JOIN bucketShuffle] hashCondition=((s2.k1 = d.k1)) otherCondition=() ---------------hashAgg[GLOBAL] -----------------PhysicalDistribute[DistributionSpecHash] -------------------hashAgg[LOCAL] ---------------------PhysicalProject -----------------------hashJoin[INNER_JOIN shuffle] hashCondition=((expr_cast(k1 as BIGINT) = c.k1)) otherCondition=() -------------------------PhysicalProject ---------------------------hashAgg[GLOBAL] -----------------------------PhysicalProject -------------------------------hashJoin[INNER_JOIN bucketShuffle] hashCondition=((a.k1 = b.k1)) otherCondition=() ---------------------------------PhysicalProject -----------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_a(a)] ---------------------------------PhysicalProject -----------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_b(b)] -------------------------PhysicalProject ---------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_c] ---------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_d(d)] - -Hint log: -Used: [shuffle]_1 -UnUsed: -SyntaxError: - -- !alternating_shuffle_shuffle_shuffle_result_on -- 1 63 16 11 2 16 24 22 @@ -951,36 +275,6 @@ SyntaxError: 3 16 35 33 4 19 46 44 --- !alternating_shuffle_shuffle_broadcast_shape_on -- -PhysicalResultSink ---PhysicalQuickSort[MERGE_SORT] -----PhysicalDistribute[DistributionSpecGather] -------PhysicalQuickSort[LOCAL_SORT] ---------hashAgg[GLOBAL] -----------PhysicalProject -------------hashJoin[INNER_JOIN broadcast] hashCondition=((s2.k1 = d.k1)) otherCondition=() ---------------hashAgg[GLOBAL] -----------------PhysicalDistribute[DistributionSpecHash] -------------------hashAgg[LOCAL] ---------------------PhysicalProject -----------------------hashJoin[INNER_JOIN shuffle] hashCondition=((expr_cast(k1 as BIGINT) = c.k1)) otherCondition=() -------------------------PhysicalProject ---------------------------hashAgg[GLOBAL] -----------------------------PhysicalProject -------------------------------hashJoin[INNER_JOIN bucketShuffle] hashCondition=((a.k1 = b.k1)) otherCondition=() ---------------------------------PhysicalProject -----------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_a(a)] ---------------------------------PhysicalProject -----------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_b(b)] -------------------------PhysicalProject ---------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_c] ---------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_d(d)] - -Hint log: -Used: [shuffle]_1 [broadcast]_2 -UnUsed: -SyntaxError: - -- !alternating_shuffle_shuffle_broadcast_result_on -- 1 63 16 11 2 16 24 22 @@ -993,34 +287,6 @@ SyntaxError: 3 16 35 33 4 19 46 44 --- !alternating_shuffle_broadcast_bucket_shape_on -- -PhysicalResultSink ---PhysicalQuickSort[MERGE_SORT] -----PhysicalDistribute[DistributionSpecGather] -------PhysicalQuickSort[LOCAL_SORT] ---------hashAgg[GLOBAL] -----------PhysicalProject -------------hashJoin[INNER_JOIN bucketShuffle] hashCondition=((s2.k1 = d.k1)) otherCondition=() ---------------hashAgg[GLOBAL] -----------------PhysicalProject -------------------hashJoin[INNER_JOIN broadcast] hashCondition=((expr_cast(k1 as BIGINT) = c.k1)) otherCondition=() ---------------------PhysicalProject -----------------------hashAgg[GLOBAL] -------------------------PhysicalProject ---------------------------hashJoin[INNER_JOIN bucketShuffle] hashCondition=((a.k1 = b.k1)) otherCondition=() -----------------------------PhysicalProject -------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_a(a)] -----------------------------PhysicalProject -------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_b(b)] ---------------------PhysicalProject -----------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_c] ---------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_d(d)] - -Hint log: -Used: [shuffle]_1 [broadcast]_2 -UnUsed: -SyntaxError: - -- !alternating_shuffle_broadcast_bucket_result_on -- 1 63 16 11 2 16 24 22 @@ -1033,34 +299,6 @@ SyntaxError: 3 16 35 33 4 19 46 44 --- !alternating_shuffle_broadcast_shuffle_shape_on -- -PhysicalResultSink ---PhysicalQuickSort[MERGE_SORT] -----PhysicalDistribute[DistributionSpecGather] -------PhysicalQuickSort[LOCAL_SORT] ---------hashAgg[GLOBAL] -----------PhysicalProject -------------hashJoin[INNER_JOIN bucketShuffle] hashCondition=((s2.k1 = d.k1)) otherCondition=() ---------------hashAgg[GLOBAL] -----------------PhysicalProject -------------------hashJoin[INNER_JOIN broadcast] hashCondition=((expr_cast(k1 as BIGINT) = c.k1)) otherCondition=() ---------------------PhysicalProject -----------------------hashAgg[GLOBAL] -------------------------PhysicalProject ---------------------------hashJoin[INNER_JOIN bucketShuffle] hashCondition=((a.k1 = b.k1)) otherCondition=() -----------------------------PhysicalProject -------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_a(a)] -----------------------------PhysicalProject -------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_b(b)] ---------------------PhysicalProject -----------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_c] ---------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_d(d)] - -Hint log: -Used: [shuffle]_1 [broadcast]_2 -UnUsed: -SyntaxError: - -- !alternating_shuffle_broadcast_shuffle_result_on -- 1 63 16 11 2 16 24 22 @@ -1073,34 +311,6 @@ SyntaxError: 3 16 35 33 4 19 46 44 --- !alternating_shuffle_broadcast_broadcast_shape_on -- -PhysicalResultSink ---PhysicalQuickSort[MERGE_SORT] -----PhysicalDistribute[DistributionSpecGather] -------PhysicalQuickSort[LOCAL_SORT] ---------hashAgg[GLOBAL] -----------PhysicalProject -------------hashJoin[INNER_JOIN broadcast] hashCondition=((s2.k1 = d.k1)) otherCondition=() ---------------hashAgg[GLOBAL] -----------------PhysicalProject -------------------hashJoin[INNER_JOIN broadcast] hashCondition=((expr_cast(k1 as BIGINT) = c.k1)) otherCondition=() ---------------------PhysicalProject -----------------------hashAgg[GLOBAL] -------------------------PhysicalProject ---------------------------hashJoin[INNER_JOIN bucketShuffle] hashCondition=((a.k1 = b.k1)) otherCondition=() -----------------------------PhysicalProject -------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_a(a)] -----------------------------PhysicalProject -------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_b(b)] ---------------------PhysicalProject -----------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_c] ---------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_d(d)] - -Hint log: -Used: [shuffle]_1 [broadcast]_2 -UnUsed: -SyntaxError: - -- !alternating_shuffle_broadcast_broadcast_result_on -- 1 63 16 11 2 16 24 22 @@ -1113,36 +323,6 @@ SyntaxError: 3 16 35 33 4 19 46 44 --- !alternating_broadcast_bucket_bucket_shape_on -- -PhysicalResultSink ---PhysicalQuickSort[MERGE_SORT] -----PhysicalDistribute[DistributionSpecGather] -------PhysicalQuickSort[LOCAL_SORT] ---------hashAgg[GLOBAL] -----------PhysicalProject -------------hashJoin[INNER_JOIN bucketShuffle] hashCondition=((s2.k1 = d.k1)) otherCondition=() ---------------hashAgg[GLOBAL] -----------------PhysicalDistribute[DistributionSpecHash] -------------------hashAgg[LOCAL] ---------------------PhysicalProject -----------------------hashJoin[INNER_JOIN shuffle] hashCondition=((expr_cast(k1 as BIGINT) = c.k1)) otherCondition=() -------------------------PhysicalProject ---------------------------hashAgg[GLOBAL] -----------------------------PhysicalProject -------------------------------hashJoin[INNER_JOIN broadcast] hashCondition=((a.k1 = b.k1)) otherCondition=() ---------------------------------PhysicalProject -----------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_a(a)] ---------------------------------PhysicalProject -----------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_b(b)] -------------------------PhysicalProject ---------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_c] ---------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_d(d)] - -Hint log: -Used: [broadcast]_1 -UnUsed: -SyntaxError: - -- !alternating_broadcast_bucket_bucket_result_on -- 1 63 16 11 2 16 24 22 @@ -1155,36 +335,6 @@ SyntaxError: 3 16 35 33 4 19 46 44 --- !alternating_broadcast_bucket_shuffle_shape_on -- -PhysicalResultSink ---PhysicalQuickSort[MERGE_SORT] -----PhysicalDistribute[DistributionSpecGather] -------PhysicalQuickSort[LOCAL_SORT] ---------hashAgg[GLOBAL] -----------PhysicalProject -------------hashJoin[INNER_JOIN bucketShuffle] hashCondition=((s2.k1 = d.k1)) otherCondition=() ---------------hashAgg[GLOBAL] -----------------PhysicalDistribute[DistributionSpecHash] -------------------hashAgg[LOCAL] ---------------------PhysicalProject -----------------------hashJoin[INNER_JOIN shuffle] hashCondition=((expr_cast(k1 as BIGINT) = c.k1)) otherCondition=() -------------------------PhysicalProject ---------------------------hashAgg[GLOBAL] -----------------------------PhysicalProject -------------------------------hashJoin[INNER_JOIN broadcast] hashCondition=((a.k1 = b.k1)) otherCondition=() ---------------------------------PhysicalProject -----------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_a(a)] ---------------------------------PhysicalProject -----------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_b(b)] -------------------------PhysicalProject ---------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_c] ---------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_d(d)] - -Hint log: -Used: [broadcast]_1 [shuffle]_2 -UnUsed: -SyntaxError: - -- !alternating_broadcast_bucket_shuffle_result_on -- 1 63 16 11 2 16 24 22 @@ -1197,36 +347,6 @@ SyntaxError: 3 16 35 33 4 19 46 44 --- !alternating_broadcast_bucket_broadcast_shape_on -- -PhysicalResultSink ---PhysicalQuickSort[MERGE_SORT] -----PhysicalDistribute[DistributionSpecGather] -------PhysicalQuickSort[LOCAL_SORT] ---------hashAgg[GLOBAL] -----------PhysicalProject -------------hashJoin[INNER_JOIN broadcast] hashCondition=((s2.k1 = d.k1)) otherCondition=() ---------------hashAgg[GLOBAL] -----------------PhysicalDistribute[DistributionSpecHash] -------------------hashAgg[LOCAL] ---------------------PhysicalProject -----------------------hashJoin[INNER_JOIN shuffle] hashCondition=((expr_cast(k1 as BIGINT) = c.k1)) otherCondition=() -------------------------PhysicalProject ---------------------------hashAgg[GLOBAL] -----------------------------PhysicalProject -------------------------------hashJoin[INNER_JOIN broadcast] hashCondition=((a.k1 = b.k1)) otherCondition=() ---------------------------------PhysicalProject -----------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_a(a)] ---------------------------------PhysicalProject -----------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_b(b)] -------------------------PhysicalProject ---------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_c] ---------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_d(d)] - -Hint log: -Used: [broadcast]_1 -UnUsed: -SyntaxError: - -- !alternating_broadcast_bucket_broadcast_result_on -- 1 63 16 11 2 16 24 22 @@ -1239,36 +359,6 @@ SyntaxError: 3 16 35 33 4 19 46 44 --- !alternating_broadcast_shuffle_bucket_shape_on -- -PhysicalResultSink ---PhysicalQuickSort[MERGE_SORT] -----PhysicalDistribute[DistributionSpecGather] -------PhysicalQuickSort[LOCAL_SORT] ---------hashAgg[GLOBAL] -----------PhysicalProject -------------hashJoin[INNER_JOIN bucketShuffle] hashCondition=((s2.k1 = d.k1)) otherCondition=() ---------------hashAgg[GLOBAL] -----------------PhysicalDistribute[DistributionSpecHash] -------------------hashAgg[LOCAL] ---------------------PhysicalProject -----------------------hashJoin[INNER_JOIN shuffle] hashCondition=((expr_cast(k1 as BIGINT) = c.k1)) otherCondition=() -------------------------PhysicalProject ---------------------------hashAgg[GLOBAL] -----------------------------PhysicalProject -------------------------------hashJoin[INNER_JOIN broadcast] hashCondition=((a.k1 = b.k1)) otherCondition=() ---------------------------------PhysicalProject -----------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_a(a)] ---------------------------------PhysicalProject -----------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_b(b)] -------------------------PhysicalProject ---------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_c] ---------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_d(d)] - -Hint log: -Used: [broadcast]_1 [shuffle]_2 -UnUsed: -SyntaxError: - -- !alternating_broadcast_shuffle_bucket_result_on -- 1 63 16 11 2 16 24 22 @@ -1281,36 +371,6 @@ SyntaxError: 3 16 35 33 4 19 46 44 --- !alternating_broadcast_shuffle_shuffle_shape_on -- -PhysicalResultSink ---PhysicalQuickSort[MERGE_SORT] -----PhysicalDistribute[DistributionSpecGather] -------PhysicalQuickSort[LOCAL_SORT] ---------hashAgg[GLOBAL] -----------PhysicalProject -------------hashJoin[INNER_JOIN bucketShuffle] hashCondition=((s2.k1 = d.k1)) otherCondition=() ---------------hashAgg[GLOBAL] -----------------PhysicalDistribute[DistributionSpecHash] -------------------hashAgg[LOCAL] ---------------------PhysicalProject -----------------------hashJoin[INNER_JOIN shuffle] hashCondition=((expr_cast(k1 as BIGINT) = c.k1)) otherCondition=() -------------------------PhysicalProject ---------------------------hashAgg[GLOBAL] -----------------------------PhysicalProject -------------------------------hashJoin[INNER_JOIN broadcast] hashCondition=((a.k1 = b.k1)) otherCondition=() ---------------------------------PhysicalProject -----------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_a(a)] ---------------------------------PhysicalProject -----------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_b(b)] -------------------------PhysicalProject ---------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_c] ---------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_d(d)] - -Hint log: -Used: [broadcast]_1 [shuffle]_2 -UnUsed: -SyntaxError: - -- !alternating_broadcast_shuffle_shuffle_result_on -- 1 63 16 11 2 16 24 22 @@ -1323,36 +383,6 @@ SyntaxError: 3 16 35 33 4 19 46 44 --- !alternating_broadcast_shuffle_broadcast_shape_on -- -PhysicalResultSink ---PhysicalQuickSort[MERGE_SORT] -----PhysicalDistribute[DistributionSpecGather] -------PhysicalQuickSort[LOCAL_SORT] ---------hashAgg[GLOBAL] -----------PhysicalProject -------------hashJoin[INNER_JOIN broadcast] hashCondition=((s2.k1 = d.k1)) otherCondition=() ---------------hashAgg[GLOBAL] -----------------PhysicalDistribute[DistributionSpecHash] -------------------hashAgg[LOCAL] ---------------------PhysicalProject -----------------------hashJoin[INNER_JOIN shuffle] hashCondition=((expr_cast(k1 as BIGINT) = c.k1)) otherCondition=() -------------------------PhysicalProject ---------------------------hashAgg[GLOBAL] -----------------------------PhysicalProject -------------------------------hashJoin[INNER_JOIN broadcast] hashCondition=((a.k1 = b.k1)) otherCondition=() ---------------------------------PhysicalProject -----------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_a(a)] ---------------------------------PhysicalProject -----------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_b(b)] -------------------------PhysicalProject ---------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_c] ---------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_d(d)] - -Hint log: -Used: [broadcast]_1 [shuffle]_2 -UnUsed: -SyntaxError: - -- !alternating_broadcast_shuffle_broadcast_result_on -- 1 63 16 11 2 16 24 22 @@ -1365,34 +395,6 @@ SyntaxError: 3 16 35 33 4 19 46 44 --- !alternating_broadcast_broadcast_bucket_shape_on -- -PhysicalResultSink ---PhysicalQuickSort[MERGE_SORT] -----PhysicalDistribute[DistributionSpecGather] -------PhysicalQuickSort[LOCAL_SORT] ---------hashAgg[GLOBAL] -----------PhysicalProject -------------hashJoin[INNER_JOIN bucketShuffle] hashCondition=((s2.k1 = d.k1)) otherCondition=() ---------------hashAgg[GLOBAL] -----------------PhysicalProject -------------------hashJoin[INNER_JOIN broadcast] hashCondition=((expr_cast(k1 as BIGINT) = c.k1)) otherCondition=() ---------------------PhysicalProject -----------------------hashAgg[GLOBAL] -------------------------PhysicalProject ---------------------------hashJoin[INNER_JOIN broadcast] hashCondition=((a.k1 = b.k1)) otherCondition=() -----------------------------PhysicalProject -------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_a(a)] -----------------------------PhysicalProject -------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_b(b)] ---------------------PhysicalProject -----------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_c] ---------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_d(d)] - -Hint log: -Used: [broadcast]_1 -UnUsed: -SyntaxError: - -- !alternating_broadcast_broadcast_bucket_result_on -- 1 63 16 11 2 16 24 22 @@ -1405,34 +407,6 @@ SyntaxError: 3 16 35 33 4 19 46 44 --- !alternating_broadcast_broadcast_shuffle_shape_on -- -PhysicalResultSink ---PhysicalQuickSort[MERGE_SORT] -----PhysicalDistribute[DistributionSpecGather] -------PhysicalQuickSort[LOCAL_SORT] ---------hashAgg[GLOBAL] -----------PhysicalProject -------------hashJoin[INNER_JOIN bucketShuffle] hashCondition=((s2.k1 = d.k1)) otherCondition=() ---------------hashAgg[GLOBAL] -----------------PhysicalProject -------------------hashJoin[INNER_JOIN broadcast] hashCondition=((expr_cast(k1 as BIGINT) = c.k1)) otherCondition=() ---------------------PhysicalProject -----------------------hashAgg[GLOBAL] -------------------------PhysicalProject ---------------------------hashJoin[INNER_JOIN broadcast] hashCondition=((a.k1 = b.k1)) otherCondition=() -----------------------------PhysicalProject -------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_a(a)] -----------------------------PhysicalProject -------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_b(b)] ---------------------PhysicalProject -----------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_c] ---------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_d(d)] - -Hint log: -Used: [broadcast]_1 [shuffle]_2 -UnUsed: -SyntaxError: - -- !alternating_broadcast_broadcast_shuffle_result_on -- 1 63 16 11 2 16 24 22 @@ -1445,34 +419,6 @@ SyntaxError: 3 16 35 33 4 19 46 44 --- !alternating_broadcast_broadcast_broadcast_shape_on -- -PhysicalResultSink ---PhysicalQuickSort[MERGE_SORT] -----PhysicalDistribute[DistributionSpecGather] -------PhysicalQuickSort[LOCAL_SORT] ---------hashAgg[GLOBAL] -----------PhysicalProject -------------hashJoin[INNER_JOIN broadcast] hashCondition=((s2.k1 = d.k1)) otherCondition=() ---------------hashAgg[GLOBAL] -----------------PhysicalProject -------------------hashJoin[INNER_JOIN broadcast] hashCondition=((expr_cast(k1 as BIGINT) = c.k1)) otherCondition=() ---------------------PhysicalProject -----------------------hashAgg[GLOBAL] -------------------------PhysicalProject ---------------------------hashJoin[INNER_JOIN broadcast] hashCondition=((a.k1 = b.k1)) otherCondition=() -----------------------------PhysicalProject -------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_a(a)] -----------------------------PhysicalProject -------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_b(b)] ---------------------PhysicalProject -----------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_c] ---------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_d(d)] - -Hint log: -Used: [broadcast]_1 -UnUsed: -SyntaxError: - -- !alternating_broadcast_broadcast_broadcast_result_on -- 1 63 16 11 2 16 24 22 @@ -1485,27 +431,6 @@ SyntaxError: 3 16 35 33 4 19 46 44 --- !window_union_all_bucket_row_number_shape_on -- -PhysicalResultSink ---PhysicalQuickSort[MERGE_SORT] -----PhysicalDistribute[DistributionSpecGather] -------PhysicalQuickSort[LOCAL_SORT] ---------hashAgg[GLOBAL] -----------PhysicalProject -------------PhysicalWindow ---------------PhysicalWindow -----------------PhysicalQuickSort[LOCAL_SORT] -------------------PhysicalProject ---------------------hashJoin[INNER_JOIN shuffle] hashCondition=((mid_q.k1 = rhs.k1)) otherCondition=() -----------------------PhysicalUnion -------------------------PhysicalDistribute[DistributionSpecExecutionAny] ---------------------------PhysicalProject -----------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_a] -------------------------PhysicalDistribute[DistributionSpecExecutionAny] ---------------------------PhysicalProject -----------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_b] -----------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_d(rhs)] - -- !window_union_all_bucket_row_number_result_on -- 1 52 4 40 2 21 3 60 @@ -1518,27 +443,6 @@ PhysicalResultSink 3 16 2 60 4 20 2 80 --- !window_union_all_bucket_window_sum_shape_on -- -PhysicalResultSink ---PhysicalQuickSort[MERGE_SORT] -----PhysicalDistribute[DistributionSpecGather] -------PhysicalQuickSort[LOCAL_SORT] ---------hashAgg[GLOBAL] -----------PhysicalProject -------------PhysicalWindow ---------------PhysicalWindow -----------------PhysicalQuickSort[LOCAL_SORT] -------------------PhysicalProject ---------------------hashJoin[INNER_JOIN shuffle] hashCondition=((mid_q.k1 = rhs.k1)) otherCondition=() -----------------------PhysicalUnion -------------------------PhysicalDistribute[DistributionSpecExecutionAny] ---------------------------PhysicalProject -----------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_a] -------------------------PhysicalDistribute[DistributionSpecExecutionAny] ---------------------------PhysicalProject -----------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_b] -----------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_d(rhs)] - -- !window_union_all_bucket_window_sum_result_on -- 1 10 13 40 2 6 7 60 @@ -1551,35 +455,6 @@ PhysicalResultSink 3 3 8 60 4 3 10 80 --- !window_union_all_shuffle_row_number_shape_on -- -PhysicalResultSink ---PhysicalQuickSort[MERGE_SORT] -----PhysicalDistribute[DistributionSpecGather] -------PhysicalQuickSort[LOCAL_SORT] ---------hashAgg[GLOBAL] -----------PhysicalProject -------------PhysicalWindow ---------------PhysicalWindow -----------------PhysicalQuickSort[LOCAL_SORT] -------------------PhysicalDistribute[DistributionSpecHash] ---------------------PhysicalProject -----------------------hashJoin[INNER_JOIN shuffle] hashCondition=((expr_cast(k1 as BIGINT) = rhs.k1)) otherCondition=() -------------------------PhysicalProject ---------------------------PhysicalUnion -----------------------------PhysicalDistribute[DistributionSpecExecutionAny] -------------------------------PhysicalProject ---------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_a] -----------------------------PhysicalDistribute[DistributionSpecExecutionAny] -------------------------------PhysicalProject ---------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_b] -------------------------PhysicalProject ---------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_c] - -Hint log: -Used: [shuffle]_1 -UnUsed: -SyntaxError: - -- !window_union_all_shuffle_row_number_result_on -- 1 208 8 44 2 21 3 21 @@ -1592,35 +467,6 @@ SyntaxError: 3 16 2 16 4 20 2 18 --- !window_union_all_shuffle_window_sum_shape_on -- -PhysicalResultSink ---PhysicalQuickSort[MERGE_SORT] -----PhysicalDistribute[DistributionSpecGather] -------PhysicalQuickSort[LOCAL_SORT] ---------hashAgg[GLOBAL] -----------PhysicalProject -------------PhysicalWindow ---------------PhysicalWindow -----------------PhysicalQuickSort[LOCAL_SORT] -------------------PhysicalDistribute[DistributionSpecHash] ---------------------PhysicalProject -----------------------hashJoin[INNER_JOIN shuffle] hashCondition=((expr_cast(k1 as BIGINT) = rhs.k1)) otherCondition=() -------------------------PhysicalProject ---------------------------PhysicalUnion -----------------------------PhysicalDistribute[DistributionSpecExecutionAny] -------------------------------PhysicalProject ---------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_a] -----------------------------PhysicalDistribute[DistributionSpecExecutionAny] -------------------------------PhysicalProject ---------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_b] -------------------------PhysicalProject ---------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_c] - -Hint log: -Used: [shuffle]_1 -UnUsed: -SyntaxError: - -- !window_union_all_shuffle_window_sum_result_on -- 1 36 26 44 2 6 7 21 @@ -1633,33 +479,6 @@ SyntaxError: 3 3 8 16 4 3 10 18 --- !window_union_all_broadcast_row_number_shape_on -- -PhysicalResultSink ---PhysicalQuickSort[MERGE_SORT] -----PhysicalDistribute[DistributionSpecGather] -------PhysicalQuickSort[LOCAL_SORT] ---------hashAgg[GLOBAL] -----------PhysicalProject -------------PhysicalWindow ---------------PhysicalWindow -----------------PhysicalQuickSort[LOCAL_SORT] -------------------PhysicalDistribute[DistributionSpecHash] ---------------------PhysicalProject -----------------------hashJoin[INNER_JOIN broadcast] hashCondition=((mid_q.k1 = rhs.k1)) otherCondition=() -------------------------PhysicalUnion ---------------------------PhysicalDistribute[DistributionSpecExecutionAny] -----------------------------PhysicalProject -------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_a] ---------------------------PhysicalDistribute[DistributionSpecExecutionAny] -----------------------------PhysicalProject -------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_b] -------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_d(rhs)] - -Hint log: -Used: [broadcast]_1 -UnUsed: -SyntaxError: - -- !window_union_all_broadcast_row_number_result_on -- 1 52 4 40 2 21 3 60 @@ -1672,33 +491,6 @@ SyntaxError: 3 16 2 60 4 20 2 80 --- !window_union_all_broadcast_window_sum_shape_on -- -PhysicalResultSink ---PhysicalQuickSort[MERGE_SORT] -----PhysicalDistribute[DistributionSpecGather] -------PhysicalQuickSort[LOCAL_SORT] ---------hashAgg[GLOBAL] -----------PhysicalProject -------------PhysicalWindow ---------------PhysicalWindow -----------------PhysicalQuickSort[LOCAL_SORT] -------------------PhysicalDistribute[DistributionSpecHash] ---------------------PhysicalProject -----------------------hashJoin[INNER_JOIN broadcast] hashCondition=((mid_q.k1 = rhs.k1)) otherCondition=() -------------------------PhysicalUnion ---------------------------PhysicalDistribute[DistributionSpecExecutionAny] -----------------------------PhysicalProject -------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_a] ---------------------------PhysicalDistribute[DistributionSpecExecutionAny] -----------------------------PhysicalProject -------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_b] -------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_d(rhs)] - -Hint log: -Used: [broadcast]_1 -UnUsed: -SyntaxError: - -- !window_union_all_broadcast_window_sum_result_on -- 1 10 13 40 2 6 7 60 @@ -1711,28 +503,6 @@ SyntaxError: 3 3 8 60 4 3 10 80 --- !window_except_bucket_row_number_shape_on -- -PhysicalResultSink ---PhysicalQuickSort[MERGE_SORT] -----PhysicalDistribute[DistributionSpecGather] -------PhysicalQuickSort[LOCAL_SORT] ---------hashAgg[GLOBAL] -----------PhysicalProject -------------PhysicalWindow ---------------PhysicalWindow -----------------PhysicalQuickSort[LOCAL_SORT] -------------------PhysicalProject ---------------------hashJoin[INNER_JOIN shuffle] hashCondition=((mid_q.k1 = rhs.k1)) otherCondition=() -----------------------PhysicalExcept -------------------------PhysicalDistribute[DistributionSpecHash] ---------------------------PhysicalProject -----------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_a] -------------------------PhysicalDistribute[DistributionSpecHash] ---------------------------PhysicalProject -----------------------------filter((test_multilevel_join_agg_local_shuffle_d.k1 = 4)) -------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_d] -----------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_d(rhs)] - -- !window_except_bucket_row_number_result_on -- 1 10 2 20 2 10 2 40 @@ -1745,28 +515,6 @@ PhysicalResultSink 3 5 1 30 4 6 1 40 --- !window_except_bucket_window_sum_shape_on -- -PhysicalResultSink ---PhysicalQuickSort[MERGE_SORT] -----PhysicalDistribute[DistributionSpecGather] -------PhysicalQuickSort[LOCAL_SORT] ---------hashAgg[GLOBAL] -----------PhysicalProject -------------PhysicalWindow ---------------PhysicalWindow -----------------PhysicalQuickSort[LOCAL_SORT] -------------------PhysicalProject ---------------------hashJoin[INNER_JOIN shuffle] hashCondition=((mid_q.k1 = rhs.k1)) otherCondition=() -----------------------PhysicalExcept -------------------------PhysicalDistribute[DistributionSpecHash] ---------------------------PhysicalProject -----------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_a] -------------------------PhysicalDistribute[DistributionSpecHash] ---------------------------PhysicalProject -----------------------------filter((test_multilevel_join_agg_local_shuffle_d.k1 = 4)) -------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_d] -----------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_d(rhs)] - -- !window_except_bucket_window_sum_result_on -- 1 3 5 20 2 3 5 40 @@ -1779,36 +527,6 @@ PhysicalResultSink 3 1 5 30 4 1 6 40 --- !window_except_shuffle_row_number_shape_on -- -PhysicalResultSink ---PhysicalQuickSort[MERGE_SORT] -----PhysicalDistribute[DistributionSpecGather] -------PhysicalQuickSort[LOCAL_SORT] ---------hashAgg[GLOBAL] -----------PhysicalProject -------------PhysicalWindow ---------------PhysicalWindow -----------------PhysicalQuickSort[LOCAL_SORT] -------------------PhysicalDistribute[DistributionSpecHash] ---------------------PhysicalProject -----------------------hashJoin[INNER_JOIN shuffle] hashCondition=((expr_cast(k1 as BIGINT) = rhs.k1)) otherCondition=() -------------------------PhysicalProject ---------------------------PhysicalExcept -----------------------------PhysicalDistribute[DistributionSpecHash] -------------------------------PhysicalProject ---------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_a] -----------------------------PhysicalDistribute[DistributionSpecHash] -------------------------------PhysicalProject ---------------------------------filter((test_multilevel_join_agg_local_shuffle_d.k1 = 4)) -----------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_d] -------------------------PhysicalProject ---------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_c] - -Hint log: -Used: [shuffle]_1 -UnUsed: -SyntaxError: - -- !window_except_shuffle_row_number_result_on -- 1 40 4 22 2 10 2 14 @@ -1821,36 +539,6 @@ SyntaxError: 3 5 1 8 4 6 1 9 --- !window_except_shuffle_window_sum_shape_on -- -PhysicalResultSink ---PhysicalQuickSort[MERGE_SORT] -----PhysicalDistribute[DistributionSpecGather] -------PhysicalQuickSort[LOCAL_SORT] ---------hashAgg[GLOBAL] -----------PhysicalProject -------------PhysicalWindow ---------------PhysicalWindow -----------------PhysicalQuickSort[LOCAL_SORT] -------------------PhysicalDistribute[DistributionSpecHash] ---------------------PhysicalProject -----------------------hashJoin[INNER_JOIN shuffle] hashCondition=((expr_cast(k1 as BIGINT) = rhs.k1)) otherCondition=() -------------------------PhysicalProject ---------------------------PhysicalExcept -----------------------------PhysicalDistribute[DistributionSpecHash] -------------------------------PhysicalProject ---------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_a] -----------------------------PhysicalDistribute[DistributionSpecHash] -------------------------------PhysicalProject ---------------------------------filter((test_multilevel_join_agg_local_shuffle_d.k1 = 4)) -----------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_d] -------------------------PhysicalProject ---------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_c] - -Hint log: -Used: [shuffle]_1 -UnUsed: -SyntaxError: - -- !window_except_shuffle_window_sum_result_on -- 1 10 10 22 2 3 5 14 @@ -1863,34 +551,6 @@ SyntaxError: 3 1 5 8 4 1 6 9 --- !window_except_broadcast_row_number_shape_on -- -PhysicalResultSink ---PhysicalQuickSort[MERGE_SORT] -----PhysicalDistribute[DistributionSpecGather] -------PhysicalQuickSort[LOCAL_SORT] ---------hashAgg[GLOBAL] -----------PhysicalProject -------------PhysicalWindow ---------------PhysicalWindow -----------------PhysicalQuickSort[LOCAL_SORT] -------------------PhysicalDistribute[DistributionSpecHash] ---------------------PhysicalProject -----------------------hashJoin[INNER_JOIN broadcast] hashCondition=((mid_q.k1 = rhs.k1)) otherCondition=() -------------------------PhysicalExcept ---------------------------PhysicalDistribute[DistributionSpecHash] -----------------------------PhysicalProject -------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_a] ---------------------------PhysicalDistribute[DistributionSpecHash] -----------------------------PhysicalProject -------------------------------filter((test_multilevel_join_agg_local_shuffle_d.k1 = 4)) ---------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_d] -------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_d(rhs)] - -Hint log: -Used: [broadcast]_1 -UnUsed: -SyntaxError: - -- !window_except_broadcast_row_number_result_on -- 1 10 2 20 2 10 2 40 @@ -1903,34 +563,6 @@ SyntaxError: 3 5 1 30 4 6 1 40 --- !window_except_broadcast_window_sum_shape_on -- -PhysicalResultSink ---PhysicalQuickSort[MERGE_SORT] -----PhysicalDistribute[DistributionSpecGather] -------PhysicalQuickSort[LOCAL_SORT] ---------hashAgg[GLOBAL] -----------PhysicalProject -------------PhysicalWindow ---------------PhysicalWindow -----------------PhysicalQuickSort[LOCAL_SORT] -------------------PhysicalDistribute[DistributionSpecHash] ---------------------PhysicalProject -----------------------hashJoin[INNER_JOIN broadcast] hashCondition=((mid_q.k1 = rhs.k1)) otherCondition=() -------------------------PhysicalExcept ---------------------------PhysicalDistribute[DistributionSpecHash] -----------------------------PhysicalProject -------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_a] ---------------------------PhysicalDistribute[DistributionSpecHash] -----------------------------PhysicalProject -------------------------------filter((test_multilevel_join_agg_local_shuffle_d.k1 = 4)) ---------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_d] -------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_d(rhs)] - -Hint log: -Used: [broadcast]_1 -UnUsed: -SyntaxError: - -- !window_except_broadcast_window_sum_result_on -- 1 3 5 20 2 3 5 40 @@ -1943,206 +575,30 @@ SyntaxError: 3 1 5 30 4 1 6 40 --- !window_intersect_bucket_row_number_shape_on -- -PhysicalResultSink ---PhysicalQuickSort[MERGE_SORT] -----PhysicalDistribute[DistributionSpecGather] -------PhysicalQuickSort[LOCAL_SORT] ---------hashAgg[GLOBAL] -----------PhysicalProject -------------PhysicalWindow ---------------PhysicalWindow -----------------PhysicalQuickSort[LOCAL_SORT] -------------------PhysicalProject ---------------------hashJoin[INNER_JOIN shuffle] hashCondition=((mid_q.k1 = rhs.k1)) otherCondition=() -----------------------PhysicalIntersect -------------------------PhysicalDistribute[DistributionSpecHash] ---------------------------PhysicalProject -----------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_a] -------------------------PhysicalDistribute[DistributionSpecHash] ---------------------------PhysicalProject -----------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_b] -----------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_d(rhs)] - -- !window_intersect_bucket_row_number_result_on -- -- !window_intersect_bucket_row_number_result_off -- --- !window_intersect_bucket_window_sum_shape_on -- -PhysicalResultSink ---PhysicalQuickSort[MERGE_SORT] -----PhysicalDistribute[DistributionSpecGather] -------PhysicalQuickSort[LOCAL_SORT] ---------hashAgg[GLOBAL] -----------PhysicalProject -------------PhysicalWindow ---------------PhysicalWindow -----------------PhysicalQuickSort[LOCAL_SORT] -------------------PhysicalProject ---------------------hashJoin[INNER_JOIN shuffle] hashCondition=((mid_q.k1 = rhs.k1)) otherCondition=() -----------------------PhysicalIntersect -------------------------PhysicalDistribute[DistributionSpecHash] ---------------------------PhysicalProject -----------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_a] -------------------------PhysicalDistribute[DistributionSpecHash] ---------------------------PhysicalProject -----------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_b] -----------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_d(rhs)] - -- !window_intersect_bucket_window_sum_result_on -- -- !window_intersect_bucket_window_sum_result_off -- --- !window_intersect_shuffle_row_number_shape_on -- -PhysicalResultSink ---PhysicalQuickSort[MERGE_SORT] -----PhysicalDistribute[DistributionSpecGather] -------PhysicalQuickSort[LOCAL_SORT] ---------hashAgg[GLOBAL] -----------PhysicalProject -------------PhysicalWindow ---------------PhysicalWindow -----------------PhysicalQuickSort[LOCAL_SORT] -------------------PhysicalDistribute[DistributionSpecHash] ---------------------PhysicalProject -----------------------hashJoin[INNER_JOIN shuffle] hashCondition=((expr_cast(k1 as BIGINT) = rhs.k1)) otherCondition=() -------------------------PhysicalProject ---------------------------PhysicalIntersect -----------------------------PhysicalDistribute[DistributionSpecHash] -------------------------------PhysicalProject ---------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_a] -----------------------------PhysicalDistribute[DistributionSpecHash] -------------------------------PhysicalProject ---------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_b] -------------------------PhysicalProject ---------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_c] - -Hint log: -Used: [shuffle]_1 -UnUsed: -SyntaxError: - -- !window_intersect_shuffle_row_number_result_on -- -- !window_intersect_shuffle_row_number_result_off -- --- !window_intersect_shuffle_window_sum_shape_on -- -PhysicalResultSink ---PhysicalQuickSort[MERGE_SORT] -----PhysicalDistribute[DistributionSpecGather] -------PhysicalQuickSort[LOCAL_SORT] ---------hashAgg[GLOBAL] -----------PhysicalProject -------------PhysicalWindow ---------------PhysicalWindow -----------------PhysicalQuickSort[LOCAL_SORT] -------------------PhysicalDistribute[DistributionSpecHash] ---------------------PhysicalProject -----------------------hashJoin[INNER_JOIN shuffle] hashCondition=((expr_cast(k1 as BIGINT) = rhs.k1)) otherCondition=() -------------------------PhysicalProject ---------------------------PhysicalIntersect -----------------------------PhysicalDistribute[DistributionSpecHash] -------------------------------PhysicalProject ---------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_a] -----------------------------PhysicalDistribute[DistributionSpecHash] -------------------------------PhysicalProject ---------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_b] -------------------------PhysicalProject ---------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_c] - -Hint log: -Used: [shuffle]_1 -UnUsed: -SyntaxError: - -- !window_intersect_shuffle_window_sum_result_on -- -- !window_intersect_shuffle_window_sum_result_off -- --- !window_intersect_broadcast_row_number_shape_on -- -PhysicalResultSink ---PhysicalQuickSort[MERGE_SORT] -----PhysicalDistribute[DistributionSpecGather] -------PhysicalQuickSort[LOCAL_SORT] ---------hashAgg[GLOBAL] -----------PhysicalProject -------------PhysicalWindow ---------------PhysicalWindow -----------------PhysicalQuickSort[LOCAL_SORT] -------------------PhysicalDistribute[DistributionSpecHash] ---------------------PhysicalProject -----------------------hashJoin[INNER_JOIN broadcast] hashCondition=((mid_q.k1 = rhs.k1)) otherCondition=() -------------------------PhysicalIntersect ---------------------------PhysicalDistribute[DistributionSpecHash] -----------------------------PhysicalProject -------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_a] ---------------------------PhysicalDistribute[DistributionSpecHash] -----------------------------PhysicalProject -------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_b] -------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_d(rhs)] - -Hint log: -Used: [broadcast]_1 -UnUsed: -SyntaxError: - -- !window_intersect_broadcast_row_number_result_on -- -- !window_intersect_broadcast_row_number_result_off -- --- !window_intersect_broadcast_window_sum_shape_on -- -PhysicalResultSink ---PhysicalQuickSort[MERGE_SORT] -----PhysicalDistribute[DistributionSpecGather] -------PhysicalQuickSort[LOCAL_SORT] ---------hashAgg[GLOBAL] -----------PhysicalProject -------------PhysicalWindow ---------------PhysicalWindow -----------------PhysicalQuickSort[LOCAL_SORT] -------------------PhysicalDistribute[DistributionSpecHash] ---------------------PhysicalProject -----------------------hashJoin[INNER_JOIN broadcast] hashCondition=((mid_q.k1 = rhs.k1)) otherCondition=() -------------------------PhysicalIntersect ---------------------------PhysicalDistribute[DistributionSpecHash] -----------------------------PhysicalProject -------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_a] ---------------------------PhysicalDistribute[DistributionSpecHash] -----------------------------PhysicalProject -------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_b] -------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_d(rhs)] - -Hint log: -Used: [broadcast]_1 -UnUsed: -SyntaxError: - -- !window_intersect_broadcast_window_sum_result_on -- -- !window_intersect_broadcast_window_sum_result_off -- --- !bucket_broadcast_agg_shape_on -- -PhysicalResultSink ---PhysicalQuickSort[MERGE_SORT] -----PhysicalDistribute[DistributionSpecGather] -------PhysicalQuickSort[LOCAL_SORT] ---------hashAgg[GLOBAL] -----------PhysicalProject -------------hashJoin[INNER_JOIN broadcast] hashCondition=((x.k1 = d.k1)) otherCondition=() ---------------hashAgg[GLOBAL] -----------------PhysicalProject -------------------hashJoin[INNER_JOIN bucketShuffle] hashCondition=((a.k1 = b.k1)) otherCondition=() ---------------------PhysicalProject -----------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_a(a)] ---------------------PhysicalProject -----------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_b(b)] ---------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_d(d)] - -Hint log: -Used: [broadcast]_1 -UnUsed: -SyntaxError: - -- !bucket_broadcast_agg_result_on -- 1 26 10 2 9 20 @@ -2155,30 +611,6 @@ SyntaxError: 3 8 30 4 10 40 --- !partitioned_broadcast_agg_shape_on -- -PhysicalResultSink ---PhysicalQuickSort[MERGE_SORT] -----PhysicalDistribute[DistributionSpecGather] -------PhysicalQuickSort[LOCAL_SORT] ---------hashAgg[GLOBAL] -----------PhysicalProject -------------hashJoin[INNER_JOIN broadcast] hashCondition=((x.k1 = d.k1)) otherCondition=() ---------------hashAgg[GLOBAL] -----------------PhysicalDistribute[DistributionSpecHash] -------------------hashAgg[LOCAL] ---------------------PhysicalProject -----------------------hashJoin[INNER_JOIN shuffle] hashCondition=((expr_cast(k1 as BIGINT) = expr_(cast(k4 as BIGINT) - 1000))) otherCondition=() -------------------------PhysicalProject ---------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_a(a)] -------------------------PhysicalProject ---------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_c(c)] ---------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_d(d)] - -Hint log: -Used: [shuffle]_1 [broadcast]_2 -UnUsed: -SyntaxError: - -- !partitioned_broadcast_agg_result_on -- 1 32 10 2 19 20 @@ -2191,31 +623,6 @@ SyntaxError: 3 13 30 4 15 40 --- !bucket_partitioned_agg_shape_on -- -PhysicalResultSink ---PhysicalQuickSort[MERGE_SORT] -----PhysicalDistribute[DistributionSpecGather] -------PhysicalQuickSort[LOCAL_SORT] ---------hashAgg[GLOBAL] -----------hashAgg[GLOBAL] -------------PhysicalDistribute[DistributionSpecHash] ---------------hashAgg[LOCAL] -----------------PhysicalProject -------------------hashJoin[INNER_JOIN shuffle] hashCondition=((expr_cast(k1 as BIGINT) = expr_(cast(k4 as BIGINT) - 1000))) otherCondition=() ---------------------PhysicalProject -----------------------hashJoin[INNER_JOIN bucketShuffle] hashCondition=((a.k1 = b.k1)) otherCondition=() -------------------------PhysicalProject ---------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_a(a)] -------------------------PhysicalProject ---------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_b(b)] ---------------------PhysicalProject -----------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_c(c)] - -Hint log: -Used: [shuffle]_1 -UnUsed: -SyntaxError: - -- !bucket_partitioned_agg_result_on -- 1 52 44 2 9 14 @@ -2228,34 +635,6 @@ SyntaxError: 3 8 8 4 10 9 --- !all_three_multilevel_agg_shape_on -- -PhysicalResultSink ---PhysicalQuickSort[MERGE_SORT] -----PhysicalDistribute[DistributionSpecGather] -------PhysicalQuickSort[LOCAL_SORT] ---------hashAgg[GLOBAL] -----------PhysicalProject -------------hashJoin[INNER_JOIN broadcast] hashCondition=((y.k1 = d.k1)) otherCondition=() ---------------hashAgg[GLOBAL] -----------------PhysicalDistribute[DistributionSpecHash] -------------------hashAgg[LOCAL] ---------------------PhysicalProject -----------------------hashJoin[INNER_JOIN shuffle] hashCondition=((expr_cast(k1 as BIGINT) = expr_(cast(k4 as BIGINT) - 1000))) otherCondition=() -------------------------PhysicalProject ---------------------------hashJoin[INNER_JOIN bucketShuffle] hashCondition=((a.k1 = b.k1)) otherCondition=() -----------------------------PhysicalProject -------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_a(a)] -----------------------------PhysicalProject -------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_b(b)] -------------------------PhysicalProject ---------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_c(c)] ---------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_d(d)] - -Hint log: -Used: [shuffle]_1 [broadcast]_2 -UnUsed: -SyntaxError: - -- !all_three_multilevel_agg_result_on -- 1 96 10 2 23 20 @@ -2268,38 +647,6 @@ SyntaxError: 3 16 30 4 19 40 --- !agg_join_agg_mix_shape_on -- -PhysicalResultSink ---PhysicalQuickSort[MERGE_SORT] -----PhysicalDistribute[DistributionSpecGather] -------PhysicalQuickSort[LOCAL_SORT] ---------hashAgg[GLOBAL] -----------PhysicalDistribute[DistributionSpecHash] -------------hashAgg[LOCAL] ---------------PhysicalProject -----------------hashJoin[INNER_JOIN broadcast] hashCondition=((l.k1 = d.k1)) otherCondition=() -------------------PhysicalProject ---------------------hashJoin[INNER_JOIN shuffleBucket] hashCondition=((expr_cast(k1 as BIGINT) = r.k1)) otherCondition=() -----------------------PhysicalProject -------------------------hashAgg[GLOBAL] ---------------------------PhysicalProject -----------------------------hashJoin[INNER_JOIN bucketShuffle] hashCondition=((a.k1 = b.k1)) otherCondition=() -------------------------------PhysicalProject ---------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_a(a)] -------------------------------PhysicalProject ---------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_b(b)] -----------------------hashAgg[GLOBAL] -------------------------PhysicalDistribute[DistributionSpecHash] ---------------------------hashAgg[LOCAL] -----------------------------PhysicalProject -------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_c(c)] -------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_d(d)] - -Hint log: -Used: [shuffle]_1 [broadcast]_2 -UnUsed: -SyntaxError: - -- !agg_join_agg_mix_result_on -- 1 10 11 10 2 5 7 20 @@ -2312,31 +659,6 @@ SyntaxError: 3 5 8 30 4 6 9 40 --- !double_broadcast_after_bucket_shape_on -- -PhysicalResultSink ---PhysicalQuickSort[MERGE_SORT] -----PhysicalDistribute[DistributionSpecGather] -------PhysicalQuickSort[LOCAL_SORT] ---------hashAgg[GLOBAL] -----------PhysicalProject -------------hashJoin[INNER_JOIN broadcast] hashCondition=((x.k1 = d2.k1)) otherCondition=() ---------------PhysicalProject -----------------hashJoin[INNER_JOIN broadcast] hashCondition=((x.k1 = d1.k1)) otherCondition=() -------------------hashAgg[GLOBAL] ---------------------PhysicalProject -----------------------hashJoin[INNER_JOIN bucketShuffle] hashCondition=((a.k1 = b.k1)) otherCondition=() -------------------------PhysicalProject ---------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_a(a)] -------------------------PhysicalProject ---------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_b(b)] -------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_d(d1)] ---------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_d(d2)] - -Hint log: -Used: [broadcast]_1 -UnUsed: -SyntaxError: - -- !double_broadcast_after_bucket_result_on -- 1 26 20 2 9 40 @@ -2349,34 +671,6 @@ SyntaxError: 3 8 60 4 10 80 --- !partitioned_join_between_two_aggs_then_broadcast_shape_on -- -PhysicalResultSink ---PhysicalQuickSort[MERGE_SORT] -----PhysicalDistribute[DistributionSpecGather] -------PhysicalQuickSort[LOCAL_SORT] ---------hashAgg[GLOBAL] -----------PhysicalDistribute[DistributionSpecHash] -------------hashAgg[LOCAL] ---------------PhysicalProject -----------------hashJoin[INNER_JOIN broadcast] hashCondition=((m.k1 = d.k1)) otherCondition=() -------------------PhysicalProject ---------------------hashJoin[INNER_JOIN shuffleBucket] hashCondition=((expr_cast(k1 as BIGINT) = r.k1)) otherCondition=() -----------------------PhysicalProject -------------------------hashAgg[GLOBAL] ---------------------------PhysicalProject -----------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_a(a)] -----------------------hashAgg[GLOBAL] -------------------------PhysicalDistribute[DistributionSpecHash] ---------------------------hashAgg[LOCAL] -----------------------------PhysicalProject -------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_c(c)] -------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_d(d)] - -Hint log: -Used: [shuffle]_1 [broadcast]_2 -UnUsed: -SyntaxError: - -- !partitioned_join_between_two_aggs_then_broadcast_result_on -- 1 16 10 2 12 20 @@ -2389,34 +683,6 @@ SyntaxError: 3 13 30 4 15 40 --- !bucket_shuffle_broadcast_two_stage_agg_shape_on -- -PhysicalResultSink ---PhysicalQuickSort[MERGE_SORT] -----PhysicalDistribute[DistributionSpecGather] -------PhysicalQuickSort[LOCAL_SORT] ---------hashAgg[GLOBAL] -----------PhysicalProject -------------hashJoin[INNER_JOIN broadcast] hashCondition=((y.k1 = d.k1)) otherCondition=() ---------------hashAgg[GLOBAL] -----------------PhysicalDistribute[DistributionSpecHash] -------------------hashAgg[LOCAL] ---------------------PhysicalProject -----------------------hashJoin[INNER_JOIN shuffle] hashCondition=((expr_cast(k1 as BIGINT) = expr_(cast(k4 as BIGINT) - 1000))) otherCondition=() -------------------------PhysicalProject ---------------------------hashJoin[INNER_JOIN bucketShuffle] hashCondition=((a.k1 = b.k1)) otherCondition=() -----------------------------PhysicalProject -------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_a(a)] -----------------------------PhysicalProject -------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_b(b)] -------------------------PhysicalProject ---------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_c(c)] ---------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_d(d)] - -Hint log: -Used: [shuffle]_1 [broadcast]_2 -UnUsed: -SyntaxError: - -- !bucket_shuffle_broadcast_two_stage_agg_result_on -- 1 52 44 10 2 9 14 20 @@ -2429,31 +695,6 @@ SyntaxError: 3 8 8 30 4 10 9 40 --- !left_join_null_preserving_with_multilevel_agg_shape_on -- -PhysicalResultSink ---PhysicalQuickSort[MERGE_SORT] -----PhysicalDistribute[DistributionSpecGather] -------PhysicalQuickSort[LOCAL_SORT] ---------hashAgg[GLOBAL] -----------PhysicalProject -------------hashJoin[LEFT_OUTER_JOIN bucketShuffle] hashCondition=((a.k1 = t.k1)) otherCondition=() ---------------PhysicalProject -----------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_a(a)] ---------------hashAgg[GLOBAL] -----------------PhysicalDistribute[DistributionSpecHash] -------------------hashAgg[LOCAL] ---------------------PhysicalProject -----------------------hashJoin[INNER_JOIN shuffle] hashCondition=((expr_cast(k1 as BIGINT) = expr_(cast(k4 as BIGINT) - 1000))) otherCondition=() -------------------------PhysicalProject ---------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_b(b)] -------------------------PhysicalProject ---------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_c(c)] - -Hint log: -Used: [shuffle]_1 -UnUsed: -SyntaxError: - -- !left_join_null_preserving_with_multilevel_agg_result_on -- 1 5 44 2 5 14 @@ -2466,45 +707,6 @@ SyntaxError: 3 5 8 4 6 9 --- !seven_layer_bucket_shuffle_broadcast_shape_on -- -PhysicalResultSink ---PhysicalQuickSort[MERGE_SORT] -----PhysicalDistribute[DistributionSpecGather] -------PhysicalQuickSort[LOCAL_SORT] ---------hashAgg[GLOBAL] -----------hashAgg[GLOBAL] -------------PhysicalProject ---------------hashJoin[INNER_JOIN broadcast] hashCondition=((m.k1 = d2.k1)) otherCondition=() -----------------hashAgg[GLOBAL] -------------------PhysicalProject ---------------------hashJoin[INNER_JOIN broadcast] hashCondition=((l.k1 = d1.k1)) otherCondition=() -----------------------hashAgg[GLOBAL] -------------------------PhysicalDistribute[DistributionSpecHash] ---------------------------hashAgg[LOCAL] -----------------------------PhysicalProject -------------------------------hashJoin[INNER_JOIN shuffleBucket] hashCondition=((expr_cast(k1 as BIGINT) = y.k1)) otherCondition=() ---------------------------------PhysicalProject -----------------------------------hashAgg[GLOBAL] -------------------------------------PhysicalProject ---------------------------------------hashJoin[INNER_JOIN bucketShuffle] hashCondition=((a.k1 = b.k1)) otherCondition=() -----------------------------------------PhysicalProject -------------------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_a(a)] -----------------------------------------PhysicalProject -------------------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_b(b)] ---------------------------------hashAgg[GLOBAL] -----------------------------------PhysicalDistribute[DistributionSpecHash] -------------------------------------hashAgg[LOCAL] ---------------------------------------PhysicalProject -----------------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_c(c)] -----------------------PhysicalProject -------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_d(d1)] -----------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_d(d2)] - -Hint log: -Used: [shuffle]_1 [broadcast]_2 -UnUsed: -SyntaxError: - -- !seven_layer_bucket_shuffle_broadcast_result_on -- 1 37 10 2 16 20 @@ -2517,38 +719,6 @@ SyntaxError: 3 16 30 4 19 40 --- !eight_layer_mixed_join_agg_chain_shape_on -- -PhysicalResultSink ---PhysicalQuickSort[MERGE_SORT] -----PhysicalDistribute[DistributionSpecGather] -------PhysicalQuickSort[LOCAL_SORT] ---------hashAgg[GLOBAL] -----------PhysicalProject -------------hashJoin[INNER_JOIN broadcast] hashCondition=((n.k1 = d2.k1)) otherCondition=() ---------------hashAgg[GLOBAL] -----------------PhysicalProject -------------------hashJoin[INNER_JOIN broadcast] hashCondition=((m.k1 = d1.k1)) otherCondition=() ---------------------hashAgg[GLOBAL] -----------------------PhysicalDistribute[DistributionSpecHash] -------------------------hashAgg[LOCAL] ---------------------------PhysicalProject -----------------------------hashJoin[INNER_JOIN shuffle] hashCondition=((expr_cast(k1 as BIGINT) = expr_(cast(k4 as BIGINT) - 1000))) otherCondition=() -------------------------------PhysicalProject ---------------------------------hashJoin[INNER_JOIN bucketShuffle] hashCondition=((a.k1 = b.k1)) otherCondition=() -----------------------------------PhysicalProject -------------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_a(a)] -----------------------------------PhysicalProject -------------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_b(b)] -------------------------------PhysicalProject ---------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_c(c)] ---------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_d(d1)] ---------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_d(d2)] - -Hint log: -Used: [shuffle]_1 [broadcast]_2 -UnUsed: -SyntaxError: - -- !eight_layer_mixed_join_agg_chain_result_on -- 1 52 44 20 2 9 14 40 @@ -2561,39 +731,6 @@ SyntaxError: 3 8 8 60 4 10 9 80 --- !seven_layer_left_join_mix_shape_on -- -PhysicalResultSink ---PhysicalQuickSort[MERGE_SORT] -----PhysicalDistribute[DistributionSpecGather] -------PhysicalQuickSort[LOCAL_SORT] ---------hashAgg[GLOBAL] -----------PhysicalProject -------------hashJoin[INNER_JOIN broadcast] hashCondition=((x.k1 = d.k1)) otherCondition=() ---------------hashAgg[GLOBAL] -----------------PhysicalDistribute[DistributionSpecHash] -------------------hashAgg[LOCAL] ---------------------PhysicalProject -----------------------hashJoin[LEFT_OUTER_JOIN shuffleBucket] hashCondition=((expr_cast(k1 as BIGINT) = r.k1)) otherCondition=() -------------------------PhysicalProject ---------------------------hashAgg[GLOBAL] -----------------------------PhysicalProject -------------------------------hashJoin[INNER_JOIN bucketShuffle] hashCondition=((a.k1 = b.k1)) otherCondition=() ---------------------------------PhysicalProject -----------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_a(a)] ---------------------------------PhysicalProject -----------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_b(b)] -------------------------hashAgg[GLOBAL] ---------------------------PhysicalDistribute[DistributionSpecHash] -----------------------------hashAgg[LOCAL] -------------------------------PhysicalProject ---------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_c(c)] ---------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_d(d)] - -Hint log: -Used: [broadcast]_1 -UnUsed: -SyntaxError: - -- !seven_layer_left_join_mix_result_on -- 1 10 11 10 2 5 7 20 @@ -2606,44 +743,6 @@ SyntaxError: 3 5 8 30 4 6 9 40 --- !broadcast_shuffle_broadcast_nested_agg_shape_on -- -PhysicalResultSink ---PhysicalQuickSort[MERGE_SORT] -----PhysicalDistribute[DistributionSpecGather] -------PhysicalQuickSort[LOCAL_SORT] ---------hashAgg[GLOBAL] -----------PhysicalProject -------------hashJoin[INNER_JOIN broadcast] hashCondition=((y.k1 = d2.k1)) otherCondition=() ---------------hashAgg[GLOBAL] -----------------PhysicalProject -------------------hashJoin[INNER_JOIN broadcast] hashCondition=((x.k1 = d1.k1)) otherCondition=() ---------------------hashAgg[GLOBAL] -----------------------PhysicalDistribute[DistributionSpecHash] -------------------------hashAgg[LOCAL] ---------------------------PhysicalProject -----------------------------hashJoin[INNER_JOIN shuffleBucket] hashCondition=((expr_cast(k1 as BIGINT) = r.k1)) otherCondition=() -------------------------------PhysicalProject ---------------------------------hashAgg[GLOBAL] -----------------------------------PhysicalProject -------------------------------------hashJoin[INNER_JOIN bucketShuffle] hashCondition=((a.k1 = b.k1)) otherCondition=() ---------------------------------------PhysicalProject -----------------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_a(a)] ---------------------------------------PhysicalProject -----------------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_b(b)] -------------------------------hashAgg[GLOBAL] ---------------------------------PhysicalDistribute[DistributionSpecHash] -----------------------------------hashAgg[LOCAL] -------------------------------------PhysicalProject ---------------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_c(c)] ---------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_d(d1)] ---------------PhysicalProject -----------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_d(d2)] - -Hint log: -Used: [shuffle]_1 [broadcast]_2 -UnUsed: -SyntaxError: - -- !broadcast_shuffle_broadcast_nested_agg_result_on -- 1 26 11 10 2 9 7 20 @@ -2656,31 +755,6 @@ SyntaxError: 3 8 8 30 4 10 9 40 --- !window_union_join_agg_shape_on -- -PhysicalResultSink ---PhysicalQuickSort[MERGE_SORT] -----PhysicalDistribute[DistributionSpecGather] -------PhysicalQuickSort[LOCAL_SORT] ---------hashAgg[GLOBAL] -----------PhysicalProject -------------hashJoin[INNER_JOIN broadcast] hashCondition=((w.k1 = d.k1)) otherCondition=() ---------------PhysicalWindow -----------------PhysicalQuickSort[LOCAL_SORT] -------------------PhysicalDistribute[DistributionSpecHash] ---------------------PhysicalUnion -----------------------PhysicalDistribute[DistributionSpecExecutionAny] -------------------------PhysicalProject ---------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_a(a)] -----------------------PhysicalDistribute[DistributionSpecExecutionAny] -------------------------PhysicalProject ---------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_b(b)] ---------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_d(d)] - -Hint log: -Used: [broadcast]_1 -UnUsed: -SyntaxError: - -- !window_union_join_agg_result_on -- 1 13 14 2 7 23 @@ -2693,34 +767,6 @@ SyntaxError: 3 8 32 4 10 42 --- !window_except_join_agg_shape_on -- -PhysicalResultSink ---PhysicalQuickSort[MERGE_SORT] -----PhysicalDistribute[DistributionSpecGather] -------PhysicalQuickSort[LOCAL_SORT] ---------hashAgg[GLOBAL] -----------PhysicalProject -------------PhysicalWindow ---------------PhysicalQuickSort[LOCAL_SORT] -----------------PhysicalWindow -------------------PhysicalQuickSort[LOCAL_SORT] ---------------------PhysicalProject -----------------------hashJoin[INNER_JOIN broadcast] hashCondition=((e.k1 = d.k1)) otherCondition=() -------------------------PhysicalExcept ---------------------------PhysicalDistribute[DistributionSpecHash] -----------------------------PhysicalProject -------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_a] ---------------------------PhysicalDistribute[DistributionSpecHash] -----------------------------PhysicalProject -------------------------------filter((test_multilevel_join_agg_local_shuffle_c.k4 = 1004)) ---------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_c] -------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_d(d)] - -Hint log: -Used: [broadcast]_1 -UnUsed: -SyntaxError: - -- !window_except_join_agg_result_on -- 1 1 10 2 1 20 @@ -2731,35 +777,6 @@ SyntaxError: 2 1 20 3 1 30 --- !window_intersect_shuffle_agg_shape_on -- -PhysicalResultSink ---PhysicalQuickSort[MERGE_SORT] -----PhysicalDistribute[DistributionSpecGather] -------PhysicalQuickSort[LOCAL_SORT] ---------hashAgg[GLOBAL] -----------PhysicalProject -------------PhysicalWindow ---------------PhysicalWindow -----------------PhysicalQuickSort[LOCAL_SORT] -------------------PhysicalDistribute[DistributionSpecHash] ---------------------PhysicalProject -----------------------hashJoin[INNER_JOIN shuffle] hashCondition=((expr_cast(k1 as BIGINT) = expr_(cast(k4 as BIGINT) - 1000))) otherCondition=() -------------------------PhysicalProject ---------------------------PhysicalIntersect -----------------------------PhysicalDistribute[DistributionSpecHash] -------------------------------PhysicalProject ---------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_a] -----------------------------PhysicalDistribute[DistributionSpecHash] -------------------------------PhysicalProject ---------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_b] -------------------------PhysicalProject ---------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_c(c)] - -Hint log: -Used: [shuffle]_1 -UnUsed: -SyntaxError: - -- !window_intersect_shuffle_agg_result_on -- 1 22 2 2 7 1 @@ -2772,38 +789,6 @@ SyntaxError: 3 8 1 4 9 1 --- !window_union_except_broadcast_agg_shape_on -- -PhysicalResultSink ---PhysicalQuickSort[MERGE_SORT] -----PhysicalDistribute[DistributionSpecGather] -------PhysicalQuickSort[LOCAL_SORT] ---------hashAgg[GLOBAL] -----------hashAgg[GLOBAL] -------------PhysicalProject ---------------hashJoin[INNER_JOIN broadcast] hashCondition=((s.k1 = d.k1)) otherCondition=() -----------------PhysicalWindow -------------------PhysicalQuickSort[LOCAL_SORT] ---------------------PhysicalDistribute[DistributionSpecHash] -----------------------PhysicalExcept -------------------------PhysicalDistribute[DistributionSpecHash] ---------------------------PhysicalUnion -----------------------------PhysicalDistribute[DistributionSpecExecutionAny] -------------------------------PhysicalProject ---------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_a] -----------------------------PhysicalDistribute[DistributionSpecExecutionAny] -------------------------------PhysicalProject ---------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_b] -------------------------PhysicalDistribute[DistributionSpecHash] ---------------------------PhysicalProject -----------------------------filter((test_multilevel_join_agg_local_shuffle_d.k1 = 4)) -------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_d] -----------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_d(d)] - -Hint log: -Used: [broadcast]_1 -UnUsed: -SyntaxError: - -- !window_union_except_broadcast_agg_result_on -- 1 13 4 10 2 7 3 20 @@ -2816,41 +801,6 @@ SyntaxError: 3 8 2 30 4 10 2 40 --- !window_setop_join_agg_chain_shape_on -- -PhysicalResultSink ---PhysicalQuickSort[MERGE_SORT] -----PhysicalDistribute[DistributionSpecGather] -------PhysicalQuickSort[LOCAL_SORT] ---------hashAgg[GLOBAL] -----------PhysicalDistribute[DistributionSpecHash] -------------hashAgg[LOCAL] ---------------PhysicalProject -----------------hashJoin[INNER_JOIN shuffle] hashCondition=((expr_cast(k1 as BIGINT) = expr_(cast(k4 as BIGINT) - 1000))) otherCondition=() -------------------PhysicalProject ---------------------PhysicalWindow -----------------------PhysicalWindow -------------------------PhysicalQuickSort[LOCAL_SORT] ---------------------------PhysicalDistribute[DistributionSpecHash] -----------------------------PhysicalUnion -------------------------------PhysicalDistribute[DistributionSpecExecutionAny] ---------------------------------PhysicalProject -----------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_a] -------------------------------PhysicalIntersect ---------------------------------PhysicalDistribute[DistributionSpecHash] -----------------------------------PhysicalProject -------------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_b] ---------------------------------PhysicalDistribute[DistributionSpecHash] -----------------------------------PhysicalProject -------------------------------------filter((test_multilevel_join_agg_local_shuffle_c.k4 >= 1001)) ---------------------------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_c] -------------------PhysicalProject ---------------------PhysicalOlapScan[test_multilevel_join_agg_local_shuffle_c(c)] - -Hint log: -Used: [shuffle]_1 -UnUsed: -SyntaxError: - -- !window_setop_join_agg_chain_result_on -- 1 20 2 22 2 10 2 14 diff --git a/regression-test/suites/query_p0/join/test_multilevel_join_agg_local_shuffle.groovy b/regression-test/suites/query_p0/join/test_multilevel_join_agg_local_shuffle.groovy index af871745700..12917553d35 100644 --- a/regression-test/suites/query_p0/join/test_multilevel_join_agg_local_shuffle.groovy +++ b/regression-test/suites/query_p0/join/test_multilevel_join_agg_local_shuffle.groovy @@ -117,8 +117,13 @@ suite("test_multilevel_join_agg_local_shuffle", "nereids_p0") { def sqlOn = sqlBody.replace("/*+SET_VAR(", "/*+SET_VAR(enable_local_shuffle_planner=true,") def sqlOff = sqlBody.replace("/*+SET_VAR(", "/*+SET_VAR(enable_local_shuffle_planner=false,") + // Plan-shape assertions removed: the FE local-shuffle planner emits its LocalExchange + // nodes *after* the Nereids physical plan, so `explain shape plan` shape is independent + // of enable_local_shuffle_planner. When the shape *does* differ, it's usually a stats- + // dependent rewrite (e.g. cost-based InferSetOperatorDistinct) and the shape check + // becomes flaky across environments. Result-equality + cross-mode equality below give + // us the actual coverage we need. sql "SET enable_local_shuffle_planner=true" - "qt_${tag}_shape_on" "explain shape plan ${sqlBody}" "order_qt_${tag}_result_on" "${sqlBody}" sql "SET enable_local_shuffle_planner=false" --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
