enable_parallel_result_sink

englefly · Sep 29, 2024 · 25a4569 · 25a4569
1 parent c3538b2
commit 25a4569
Show file tree

Hide file tree

Showing 100 changed files with 100 additions and 0 deletions.
diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/ddl/shape.tmpl b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/ddl/shape.tmpl
@@ -40,6 +40,7 @@ suite("query{--}") {
          set enable_fold_constant_by_be = false;
          set push_topn_to_agg = true;
          set TOPN_OPT_LIMIT_THRESHOLD = 1024;
+         set enable_parallel_result_sink=true;
          """
     qt_ds_shape_{--} '''
     explain shape plan

diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query1.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query1.groovy
@@ -40,6 +40,7 @@ suite("query1") {
          set enable_fold_constant_by_be = false;
          set push_topn_to_agg = true;
          set TOPN_OPT_LIMIT_THRESHOLD = 1024;
+         set enable_parallel_result_sink=true;
          """
     qt_ds_shape_1 '''
     explain shape plan

diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query10.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query10.groovy
@@ -40,6 +40,7 @@ suite("query10") {
          set enable_fold_constant_by_be = false;
          set push_topn_to_agg = true;
          set TOPN_OPT_LIMIT_THRESHOLD = 1024;
+         set enable_parallel_result_sink=true;
          """
     qt_ds_shape_10 '''
     explain shape plan

diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query11.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query11.groovy
@@ -40,6 +40,7 @@ suite("query11") {
          set enable_fold_constant_by_be = false;
          set push_topn_to_agg = true;
          set TOPN_OPT_LIMIT_THRESHOLD = 1024;
+         set enable_parallel_result_sink=true;
          """
     qt_ds_shape_11 '''
     explain shape plan

diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query12.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query12.groovy
@@ -40,6 +40,7 @@ suite("query12") {
          set enable_fold_constant_by_be = false;
          set push_topn_to_agg = true;
          set TOPN_OPT_LIMIT_THRESHOLD = 1024;
+         set enable_parallel_result_sink=true;
          """
     qt_ds_shape_12 '''
     explain shape plan

diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query13.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query13.groovy
@@ -40,6 +40,7 @@ suite("query13") {
          set enable_fold_constant_by_be = false;
          set push_topn_to_agg = true;
          set TOPN_OPT_LIMIT_THRESHOLD = 1024;
+         set enable_parallel_result_sink=true;
          """
     qt_ds_shape_13 '''
     explain shape plan

diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query14.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query14.groovy
@@ -40,6 +40,7 @@ suite("query14") {
          set enable_fold_constant_by_be = false;
          set push_topn_to_agg = true;
          set TOPN_OPT_LIMIT_THRESHOLD = 1024;
+         set enable_parallel_result_sink=true;
          """
     qt_ds_shape_14 '''
     explain shape plan

diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query15.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query15.groovy
@@ -40,6 +40,7 @@ suite("query15") {
          set enable_fold_constant_by_be = false;
          set push_topn_to_agg = true;
          set TOPN_OPT_LIMIT_THRESHOLD = 1024;
+         set enable_parallel_result_sink=true;
          """
     qt_ds_shape_15 '''
     explain shape plan

diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query16.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query16.groovy
@@ -40,6 +40,7 @@ suite("query16") {
          set enable_fold_constant_by_be = false;
          set push_topn_to_agg = true;
          set TOPN_OPT_LIMIT_THRESHOLD = 1024;
+         set enable_parallel_result_sink=true;
          """
     qt_ds_shape_16 '''
     explain shape plan

diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query17.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query17.groovy
@@ -40,6 +40,7 @@ suite("query17") {
          set enable_fold_constant_by_be = false;
          set push_topn_to_agg = true;
          set TOPN_OPT_LIMIT_THRESHOLD = 1024;
+         set enable_parallel_result_sink=true;
          """
     qt_ds_shape_17 '''
     explain shape plan

diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query18.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query18.groovy
@@ -40,6 +40,7 @@ suite("query18") {
          set enable_fold_constant_by_be = false;
          set push_topn_to_agg = true;
          set TOPN_OPT_LIMIT_THRESHOLD = 1024;
+         set enable_parallel_result_sink=true;
          """
     qt_ds_shape_18 '''
     explain shape plan

diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query19.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query19.groovy
@@ -40,6 +40,7 @@ suite("query19") {
          set enable_fold_constant_by_be = false;
          set push_topn_to_agg = true;
          set TOPN_OPT_LIMIT_THRESHOLD = 1024;
+         set enable_parallel_result_sink=true;
          """
     qt_ds_shape_19 '''
     explain shape plan

diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query2.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query2.groovy
@@ -40,6 +40,7 @@ suite("query2") {
          set enable_fold_constant_by_be = false;
          set push_topn_to_agg = true;
          set TOPN_OPT_LIMIT_THRESHOLD = 1024;
+         set enable_parallel_result_sink=true;
          """
     qt_ds_shape_2 '''
     explain shape plan

diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query20.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query20.groovy
@@ -40,6 +40,7 @@ suite("query20") {
          set enable_fold_constant_by_be = false;
          set push_topn_to_agg = true;
          set TOPN_OPT_LIMIT_THRESHOLD = 1024;
+         set enable_parallel_result_sink=true;
          """
     qt_ds_shape_20 '''
     explain shape plan

diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query21.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query21.groovy
@@ -40,6 +40,7 @@ suite("query21") {
          set enable_fold_constant_by_be = false;
          set push_topn_to_agg = true;
          set TOPN_OPT_LIMIT_THRESHOLD = 1024;
+         set enable_parallel_result_sink=true;
          """
     qt_ds_shape_21 '''
     explain shape plan

diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query22.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query22.groovy
@@ -40,6 +40,7 @@ suite("query22") {
          set enable_fold_constant_by_be = false;
          set push_topn_to_agg = true;
          set TOPN_OPT_LIMIT_THRESHOLD = 1024;
+         set enable_parallel_result_sink=true;
          """
     qt_ds_shape_22 '''
     explain shape plan

diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query23.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query23.groovy
@@ -40,6 +40,7 @@ suite("query23") {
          set enable_fold_constant_by_be = false;
          set push_topn_to_agg = true;
          set TOPN_OPT_LIMIT_THRESHOLD = 1024;
+         set enable_parallel_result_sink=true;
          """
     qt_ds_shape_23 '''
     explain shape plan

diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query24.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query24.groovy
@@ -40,6 +40,7 @@ suite("query24") {
          set enable_fold_constant_by_be = false;
          set push_topn_to_agg = true;
          set TOPN_OPT_LIMIT_THRESHOLD = 1024;
+         set enable_parallel_result_sink=true;
          """
     qt_ds_shape_24 '''
     explain shape plan

diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query25.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query25.groovy
@@ -40,6 +40,7 @@ suite("query25") {
          set enable_fold_constant_by_be = false;
          set push_topn_to_agg = true;
          set TOPN_OPT_LIMIT_THRESHOLD = 1024;
+         set enable_parallel_result_sink=true;
          """
     qt_ds_shape_25 '''
     explain shape plan

diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query26.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query26.groovy
@@ -40,6 +40,7 @@ suite("query26") {
          set enable_fold_constant_by_be = false;
          set push_topn_to_agg = true;
          set TOPN_OPT_LIMIT_THRESHOLD = 1024;
+         set enable_parallel_result_sink=true;
          """
     qt_ds_shape_26 '''
     explain shape plan

diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query27.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query27.groovy
@@ -40,6 +40,7 @@ suite("query27") {
          set enable_fold_constant_by_be = false;
          set push_topn_to_agg = true;
          set TOPN_OPT_LIMIT_THRESHOLD = 1024;
+         set enable_parallel_result_sink=true;
          """
     qt_ds_shape_27 '''
     explain shape plan

diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query28.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query28.groovy
@@ -40,6 +40,7 @@ suite("query28") {
          set enable_fold_constant_by_be = false;
          set push_topn_to_agg = true;
          set TOPN_OPT_LIMIT_THRESHOLD = 1024;
+         set enable_parallel_result_sink=true;
          """
     qt_ds_shape_28 '''
     explain shape plan

diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query29.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query29.groovy
@@ -40,6 +40,7 @@ suite("query29") {
          set enable_fold_constant_by_be = false;
          set push_topn_to_agg = true;
          set TOPN_OPT_LIMIT_THRESHOLD = 1024;
+         set enable_parallel_result_sink=true;
          """
     qt_ds_shape_29 '''
     explain shape plan

diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query3.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query3.groovy
@@ -40,6 +40,7 @@ suite("query3") {
          set enable_fold_constant_by_be = false;
          set push_topn_to_agg = true;
          set TOPN_OPT_LIMIT_THRESHOLD = 1024;
+         set enable_parallel_result_sink=true;
          """
     qt_ds_shape_3 '''
     explain shape plan

diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query30.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query30.groovy
@@ -40,6 +40,7 @@ suite("query30") {
          set enable_fold_constant_by_be = false;
          set push_topn_to_agg = true;
          set TOPN_OPT_LIMIT_THRESHOLD = 1024;
+         set enable_parallel_result_sink=true;
          """
     qt_ds_shape_30 '''
     explain shape plan

diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query31.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query31.groovy
@@ -40,6 +40,7 @@ suite("query31") {
          set enable_fold_constant_by_be = false;
          set push_topn_to_agg = true;
          set TOPN_OPT_LIMIT_THRESHOLD = 1024;
+         set enable_parallel_result_sink=true;
          """
     qt_ds_shape_31 '''
     explain shape plan

diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query32.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query32.groovy
@@ -40,6 +40,7 @@ suite("query32") {
          set enable_fold_constant_by_be = false;
          set push_topn_to_agg = true;
          set TOPN_OPT_LIMIT_THRESHOLD = 1024;
+         set enable_parallel_result_sink=true;
          """
     qt_ds_shape_32 '''
     explain shape plan

diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query33.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query33.groovy
@@ -40,6 +40,7 @@ suite("query33") {
          set enable_fold_constant_by_be = false;
          set push_topn_to_agg = true;
          set TOPN_OPT_LIMIT_THRESHOLD = 1024;
+         set enable_parallel_result_sink=true;
          """
     qt_ds_shape_33 '''
     explain shape plan

diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query34.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query34.groovy
@@ -40,6 +40,7 @@ suite("query34") {
          set enable_fold_constant_by_be = false;
          set push_topn_to_agg = true;
          set TOPN_OPT_LIMIT_THRESHOLD = 1024;
+         set enable_parallel_result_sink=true;
          """
     qt_ds_shape_34 '''
     explain shape plan

diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query35.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query35.groovy
@@ -40,6 +40,7 @@ suite("query35") {
          set enable_fold_constant_by_be = false;
          set push_topn_to_agg = true;
          set TOPN_OPT_LIMIT_THRESHOLD = 1024;
+         set enable_parallel_result_sink=true;
          """
     qt_ds_shape_35 '''
     explain shape plan

diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query36.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query36.groovy
@@ -40,6 +40,7 @@ suite("query36") {
          set enable_fold_constant_by_be = false;
          set push_topn_to_agg = true;
          set TOPN_OPT_LIMIT_THRESHOLD = 1024;
+         set enable_parallel_result_sink=true;
          """
     qt_ds_shape_36 '''
     explain shape plan

diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query37.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query37.groovy
@@ -40,6 +40,7 @@ suite("query37") {
          set enable_fold_constant_by_be = false;
          set push_topn_to_agg = true;
          set TOPN_OPT_LIMIT_THRESHOLD = 1024;
+         set enable_parallel_result_sink=true;
          """
     qt_ds_shape_37 '''
     explain shape plan

diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query38.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query38.groovy
@@ -40,6 +40,7 @@ suite("query38") {
          set enable_fold_constant_by_be = false;
          set push_topn_to_agg = true;
          set TOPN_OPT_LIMIT_THRESHOLD = 1024;
+         set enable_parallel_result_sink=true;
          """
     qt_ds_shape_38 '''
     explain shape plan

diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query39.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query39.groovy
@@ -40,6 +40,7 @@ suite("query39") {
          set enable_fold_constant_by_be = false;
          set push_topn_to_agg = true;
          set TOPN_OPT_LIMIT_THRESHOLD = 1024;
+         set enable_parallel_result_sink=true;
          """
     qt_ds_shape_39 '''
     explain shape plan

diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query4.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query4.groovy
@@ -40,6 +40,7 @@ suite("query4") {
          set enable_fold_constant_by_be = false;
          set push_topn_to_agg = true;
          set TOPN_OPT_LIMIT_THRESHOLD = 1024;
+         set enable_parallel_result_sink=true;
          """
     qt_ds_shape_4 '''
     explain shape plan

diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query40.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query40.groovy
@@ -40,6 +40,7 @@ suite("query40") {
          set enable_fold_constant_by_be = false;
          set push_topn_to_agg = true;
          set TOPN_OPT_LIMIT_THRESHOLD = 1024;
+         set enable_parallel_result_sink=true;
          """
     qt_ds_shape_40 '''
     explain shape plan

diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query41.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query41.groovy
@@ -40,6 +40,7 @@ suite("query41") {
          set enable_fold_constant_by_be = false;
          set push_topn_to_agg = true;
          set TOPN_OPT_LIMIT_THRESHOLD = 1024;
+         set enable_parallel_result_sink=true;
          """
     qt_ds_shape_41 '''
     explain shape plan

diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query42.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query42.groovy
@@ -40,6 +40,7 @@ suite("query42") {
          set enable_fold_constant_by_be = false;
          set push_topn_to_agg = true;
          set TOPN_OPT_LIMIT_THRESHOLD = 1024;
+         set enable_parallel_result_sink=true;
          """
     qt_ds_shape_42 '''
     explain shape plan

diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query43.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query43.groovy
@@ -40,6 +40,7 @@ suite("query43") {
          set enable_fold_constant_by_be = false;
          set push_topn_to_agg = true;
          set TOPN_OPT_LIMIT_THRESHOLD = 1024;
+         set enable_parallel_result_sink=true;
          """
     qt_ds_shape_43 '''
     explain shape plan

diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query44.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query44.groovy
@@ -40,6 +40,7 @@ suite("query44") {
          set enable_fold_constant_by_be = false;
          set push_topn_to_agg = true;
          set TOPN_OPT_LIMIT_THRESHOLD = 1024;
+         set enable_parallel_result_sink=true;
          """
     qt_ds_shape_44 '''
     explain shape plan

diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query45.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query45.groovy
@@ -40,6 +40,7 @@ suite("query45") {
          set enable_fold_constant_by_be = false;
          set push_topn_to_agg = true;
          set TOPN_OPT_LIMIT_THRESHOLD = 1024;
+         set enable_parallel_result_sink=true;
          """
     qt_ds_shape_45 '''
     explain shape plan

diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query46.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query46.groovy
@@ -40,6 +40,7 @@ suite("query46") {
          set enable_fold_constant_by_be = false;
          set push_topn_to_agg = true;
          set TOPN_OPT_LIMIT_THRESHOLD = 1024;
+         set enable_parallel_result_sink=true;
          """
     qt_ds_shape_46 '''
     explain shape plan

diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query47.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query47.groovy
@@ -40,6 +40,7 @@ suite("query47") {
          set enable_fold_constant_by_be = false;
          set push_topn_to_agg = true;
          set TOPN_OPT_LIMIT_THRESHOLD = 1024;
+         set enable_parallel_result_sink=true;
          """
     qt_ds_shape_47 '''
     explain shape plan

diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query48.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query48.groovy
@@ -40,6 +40,7 @@ suite("query48") {
          set enable_fold_constant_by_be = false;
          set push_topn_to_agg = true;
          set TOPN_OPT_LIMIT_THRESHOLD = 1024;
+         set enable_parallel_result_sink=true;
          """
     qt_ds_shape_48 '''
     explain shape plan

diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query49.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query49.groovy
@@ -40,6 +40,7 @@ suite("query49") {
          set enable_fold_constant_by_be = false;
          set push_topn_to_agg = true;
          set TOPN_OPT_LIMIT_THRESHOLD = 1024;
+         set enable_parallel_result_sink=true;
          """
     qt_ds_shape_49 '''
     explain shape plan

diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query5.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query5.groovy
@@ -40,6 +40,7 @@ suite("query5") {
          set enable_fold_constant_by_be = false;
          set push_topn_to_agg = true;
          set TOPN_OPT_LIMIT_THRESHOLD = 1024;
+         set enable_parallel_result_sink=true;
          """
     qt_ds_shape_5 '''
     explain shape plan

diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query50.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query50.groovy
@@ -40,6 +40,7 @@ suite("query50") {
          set enable_fold_constant_by_be = false;
          set push_topn_to_agg = true;
          set TOPN_OPT_LIMIT_THRESHOLD = 1024;
+         set enable_parallel_result_sink=true;
          """
     qt_ds_shape_50 '''
     explain shape plan

diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query51.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query51.groovy
@@ -40,6 +40,7 @@ suite("query51") {
          set enable_fold_constant_by_be = false;
          set push_topn_to_agg = true;
          set TOPN_OPT_LIMIT_THRESHOLD = 1024;
+         set enable_parallel_result_sink=true;
          """
     qt_ds_shape_51 '''
     explain shape plan

diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query52.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query52.groovy
@@ -40,6 +40,7 @@ suite("query52") {
          set enable_fold_constant_by_be = false;
          set push_topn_to_agg = true;
          set TOPN_OPT_LIMIT_THRESHOLD = 1024;
+         set enable_parallel_result_sink=true;
          """
     qt_ds_shape_52 '''
     explain shape plan

diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query53.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query53.groovy
@@ -40,6 +40,7 @@ suite("query53") {
          set enable_fold_constant_by_be = false;
          set push_topn_to_agg = true;
          set TOPN_OPT_LIMIT_THRESHOLD = 1024;
+         set enable_parallel_result_sink=true;
          """
     qt_ds_shape_53 '''
     explain shape plan