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
index 94ffc3df2ab587..9a26f444e293cc 100644
--- 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
index 6fd487b1b13e6b..b09ba3749dc821 100644
--- 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
index b2c5a253ddc626..4cbb1818b6dc9e 100644
--- 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
index fb6ce7431a9672..482ceb763132ab 100644
--- 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
index b28c3b2dc7c2cf..f9f85398b2ec2c 100644
--- 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
index d0b22c8711a782..a2f8a97e11fb00 100644
--- 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
index 02588b106d1f77..716356b71b9010 100644
--- 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
index 960d0fe3a2ef0b..08b775a0b4cd2c 100644
--- 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
index cbd95d551bdcfa..2d06cc887c559e 100644
--- 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
index 43940a9c09e220..36de5b71d2f314 100644
--- 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
index 146d1b3e288dcc..9f06b83351db74 100644
--- 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
index 8f8e7e7f3119dd..0a90db8a7bb304 100644
--- 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
index 5d9aeca57187bd..eafbc743cd5072 100644
--- 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
index b883bb2e954123..633310f974d7c4 100644
--- 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
index e51d4eda44743c..fb2d3590c054d2 100644
--- 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
index 541c834a803812..d5b76e556249c6 100644
--- 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
index ad04ac01030873..a21c4feef86155 100644
--- 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
index a8bec14593d3fe..eec85d0f8356cf 100644
--- 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
index 736cafac4ab407..eae27a1e818a70 100644
--- 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
index e25cc6de9226b0..6f9e1973c7d8f3 100644
--- 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
index b4b053c24fe72e..239e57f4eaac19 100644
--- 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
index f93dca39432185..74fcddd47057a7 100644
--- 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
index 6d9e2c966290b6..ec3b30e36a169e 100644
--- 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
index 402efe913b1553..eeced1e881f0dc 100644
--- 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
index 4acbd442bde921..3abaaa8862cb91 100644
--- 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
index db743a0be5a944..381484660a7d92 100644
--- 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
index c5a6aad9350e2b..934c962261e899 100644
--- 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
index 1bc52e16cd9b7a..448b6332e8f734 100644
--- 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
index 147a8919f88397..80acc7f72e5ab2 100644
--- 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
index 4c2bf70d4285d7..9ba8368f3c1147 100644
--- 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
index 105154bd5ffd62..b02cf7ceec4ad3 100644
--- 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
index 21c90edd256e64..bc891808012e28 100644
--- 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
index 02a9b14da743d9..2edb416929885f 100644
--- 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
index 559096b25ccfb5..ee3d855f57361c 100644
--- 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
index 62cec3786a02c8..76ab78c6274c62 100644
--- 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
index da170867391639..862bfafcfe1d4c 100644
--- 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
index f152006e931205..f0d71886c58d15 100644
--- 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
index d8165496028571..f15088227fb372 100644
--- 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
index 602728a4ff22bb..9d5e94bd7fb25e 100644
--- 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
index b4b4df91fd65a8..19416a0a2b8513 100644
--- 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
index 3d50047538c79c..b0efcedf71157d 100644
--- 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
index 6fba922ee428ca..010ca3d08934d5 100644
--- 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
index cb8e5506f02b44..68f186f6eb0176 100644
--- 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
index b4d1ce03722058..cb5966bb03e9b7 100644
--- 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
index f43a6c50cbd4e0..87d5898934809b 100644
--- 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
index a537bad3476c65..7a017fe9bd5517 100644
--- 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
index decb7a15974f50..bc933c42d03a23 100644
--- 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
index 73473696db20f2..79d7dd575ca11f 100644
--- 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
index 4fdba8ca909e14..2d4a8489f01241 100644
--- 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
index 68c2458d0f192e..3c50571c57950b 100644
--- 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
diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query54.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query54.groovy
index 8cc4512b282c1e..277edbe3f33466 100644
--- a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query54.groovy
+++ b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query54.groovy
@@ -40,6 +40,7 @@ suite("query54") {
          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_54 '''
     explain shape plan
diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query55.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query55.groovy
index 255b6eeb844935..407c432af68c2d 100644
--- a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query55.groovy
+++ b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query55.groovy
@@ -40,6 +40,7 @@ suite("query55") {
          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_55 '''
     explain shape plan
diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query56.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query56.groovy
index c3779c89a4b068..525032cc4c662e 100644
--- a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query56.groovy
+++ b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query56.groovy
@@ -40,6 +40,7 @@ suite("query56") {
          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_56 '''
     explain shape plan
diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query57.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query57.groovy
index 0c01b5efe7f50c..570ccdf8b625ce 100644
--- a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query57.groovy
+++ b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query57.groovy
@@ -40,6 +40,7 @@ suite("query57") {
          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_57 '''
     explain shape plan
diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query58.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query58.groovy
index 7667e26c8d9bd0..ed78699b0b6610 100644
--- a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query58.groovy
+++ b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query58.groovy
@@ -40,6 +40,7 @@ suite("query58") {
          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_58 '''
     explain shape plan
diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query59.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query59.groovy
index e450b4563deb52..7c0e3126fb0095 100644
--- a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query59.groovy
+++ b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query59.groovy
@@ -40,6 +40,7 @@ suite("query59") {
          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_59 '''
     explain shape plan
diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query6.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query6.groovy
index 42bd7a41841ad8..e51edf7df0a8f0 100644
--- a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query6.groovy
+++ b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query6.groovy
@@ -40,6 +40,7 @@ suite("query6") {
          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_6 '''
     explain shape plan
diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query60.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query60.groovy
index d73d7361c9688f..595f8dd65a0f58 100644
--- a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query60.groovy
+++ b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query60.groovy
@@ -40,6 +40,7 @@ suite("query60") {
          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_60 '''
     explain shape plan
diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query61.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query61.groovy
index 753a5ab395e3b3..9078b2735829e2 100644
--- a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query61.groovy
+++ b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query61.groovy
@@ -40,6 +40,7 @@ suite("query61") {
          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_61 '''
     explain shape plan
diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query62.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query62.groovy
index ae247691b87b12..cf01109c779294 100644
--- a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query62.groovy
+++ b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query62.groovy
@@ -40,6 +40,7 @@ suite("query62") {
          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_62 '''
     explain shape plan
diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query63.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query63.groovy
index 77b01b978106b7..17f99583c11ee9 100644
--- a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query63.groovy
+++ b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query63.groovy
@@ -40,6 +40,7 @@ suite("query63") {
          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_63 '''
     explain shape plan
diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query64.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query64.groovy
index 65f4ffb3e4464f..82087de873ceff 100644
--- a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query64.groovy
+++ b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query64.groovy
@@ -40,6 +40,7 @@ suite("query64") {
          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_64 '''
     explain shape plan
diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query65.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query65.groovy
index 0264fe2f2c8b2f..6369f02078c700 100644
--- a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query65.groovy
+++ b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query65.groovy
@@ -40,6 +40,7 @@ suite("query65") {
          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_65 '''
     explain shape plan
diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query66.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query66.groovy
index 2bcfed4f628818..450c224b70963b 100644
--- a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query66.groovy
+++ b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query66.groovy
@@ -40,6 +40,7 @@ suite("query66") {
          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_66 '''
     explain shape plan
diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query67.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query67.groovy
index a8833b470b39d6..9c066e838416a6 100644
--- a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query67.groovy
+++ b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query67.groovy
@@ -40,6 +40,7 @@ suite("query67") {
          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_67 '''
     explain shape plan
diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query68.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query68.groovy
index 469750f6d86c6b..ada357640a4b0c 100644
--- a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query68.groovy
+++ b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query68.groovy
@@ -40,6 +40,7 @@ suite("query68") {
          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_68 '''
     explain shape plan
diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query69.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query69.groovy
index d8d6ded3c21ac8..73e9ebdd0529f5 100644
--- a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query69.groovy
+++ b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query69.groovy
@@ -40,6 +40,7 @@ suite("query69") {
          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_69 '''
     explain shape plan
diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query7.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query7.groovy
index 40f223ab7c1c77..cb18f6341a43ca 100644
--- a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query7.groovy
+++ b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query7.groovy
@@ -40,6 +40,7 @@ suite("query7") {
          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_7 '''
     explain shape plan
diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query70.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query70.groovy
index 145638e15c120d..79b189284e60fa 100644
--- a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query70.groovy
+++ b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query70.groovy
@@ -40,6 +40,7 @@ suite("query70") {
          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_70 '''
     explain shape plan
diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query71.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query71.groovy
index 5812864fda89c7..6bfb2633732647 100644
--- a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query71.groovy
+++ b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query71.groovy
@@ -40,6 +40,7 @@ suite("query71") {
          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_71 '''
     explain shape plan
diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query72.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query72.groovy
index f1422b5a0410ab..9ef1f85a4d6505 100644
--- a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query72.groovy
+++ b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query72.groovy
@@ -40,6 +40,7 @@ suite("query72") {
          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_72 '''
     explain shape plan
diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query73.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query73.groovy
index 2a7b3ebb864526..1da37f1f77c904 100644
--- a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query73.groovy
+++ b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query73.groovy
@@ -40,6 +40,7 @@ suite("query73") {
          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_73 '''
     explain shape plan
diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query74.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query74.groovy
index ffa13ea03cdbd6..fb06f43c8520bb 100644
--- a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query74.groovy
+++ b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query74.groovy
@@ -40,6 +40,7 @@ suite("query74") {
          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_74 '''
     explain shape plan
diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query75.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query75.groovy
index 03c494071b96be..8dec01afbd9f1c 100644
--- a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query75.groovy
+++ b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query75.groovy
@@ -40,6 +40,7 @@ suite("query75") {
          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_75 '''
     explain shape plan
diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query76.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query76.groovy
index 2ab747a71eba49..b9de4e0243d327 100644
--- a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query76.groovy
+++ b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query76.groovy
@@ -40,6 +40,7 @@ suite("query76") {
          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_76 '''
     explain shape plan
diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query77.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query77.groovy
index adbfdb30a5d574..7b966b5c10c17c 100644
--- a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query77.groovy
+++ b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query77.groovy
@@ -40,6 +40,7 @@ suite("query77") {
          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_77 '''
     explain shape plan
diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query78.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query78.groovy
index 2272daeb2b988e..74bb2ecbaa6344 100644
--- a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query78.groovy
+++ b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query78.groovy
@@ -40,6 +40,7 @@ suite("query78") {
          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_78 '''
     explain shape plan
diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query79.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query79.groovy
index 1512ba4981dbaa..eb66d7bb3e9648 100644
--- a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query79.groovy
+++ b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query79.groovy
@@ -40,6 +40,7 @@ suite("query79") {
          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_79 '''
     explain shape plan
diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query8.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query8.groovy
index 819e742414447f..428594e4e509d4 100644
--- a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query8.groovy
+++ b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query8.groovy
@@ -40,6 +40,7 @@ suite("query8") {
          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_8 '''
     explain shape plan
diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query80.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query80.groovy
index 845df49c32eebf..f4d3ed5847097c 100644
--- a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query80.groovy
+++ b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query80.groovy
@@ -40,6 +40,7 @@ suite("query80") {
          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_80 '''
     explain shape plan
diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query81.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query81.groovy
index 0f55842cf37ca1..05a51faffa8ffc 100644
--- a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query81.groovy
+++ b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query81.groovy
@@ -40,6 +40,7 @@ suite("query81") {
          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_81 '''
     explain shape plan
diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query82.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query82.groovy
index c436c6288679ca..6a17545e339bde 100644
--- a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query82.groovy
+++ b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query82.groovy
@@ -40,6 +40,7 @@ suite("query82") {
          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_82 '''
     explain shape plan
diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query83.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query83.groovy
index fc01492c721f32..37565aa1cbca98 100644
--- a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query83.groovy
+++ b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query83.groovy
@@ -40,6 +40,7 @@ suite("query83") {
          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_83 '''
     explain shape plan
diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query84.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query84.groovy
index b86e88d1ea7999..33e97e1c257114 100644
--- a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query84.groovy
+++ b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query84.groovy
@@ -40,6 +40,7 @@ suite("query84") {
          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_84 '''
     explain shape plan
diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query85.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query85.groovy
index f04a8cf0f02765..d7c71bd0a32701 100644
--- a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query85.groovy
+++ b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query85.groovy
@@ -40,6 +40,7 @@ suite("query85") {
          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_85 '''
     explain shape plan
diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query86.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query86.groovy
index 45331da8c570a8..0d6d1d88d7cbdb 100644
--- a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query86.groovy
+++ b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query86.groovy
@@ -40,6 +40,7 @@ suite("query86") {
          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_86 '''
     explain shape plan
diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query87.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query87.groovy
index 8863236f6856fe..7e9d529b96a203 100644
--- a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query87.groovy
+++ b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query87.groovy
@@ -40,6 +40,7 @@ suite("query87") {
          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_87 '''
     explain shape plan
diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query88.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query88.groovy
index 844c17aa7950c0..e5b0f1e665f729 100644
--- a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query88.groovy
+++ b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query88.groovy
@@ -40,6 +40,7 @@ suite("query88") {
          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_88 '''
     explain shape plan
diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query89.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query89.groovy
index 1b5ffcfa8209da..bbd6a98205bfac 100644
--- a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query89.groovy
+++ b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query89.groovy
@@ -40,6 +40,7 @@ suite("query89") {
          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_89 '''
     explain shape plan
diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query9.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query9.groovy
index 727f88ed76f987..026e327d4b9713 100644
--- a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query9.groovy
+++ b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query9.groovy
@@ -40,6 +40,7 @@ suite("query9") {
          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_9 '''
     explain shape plan
diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query90.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query90.groovy
index 7daa11d3a7d964..d23f0714d0da97 100644
--- a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query90.groovy
+++ b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query90.groovy
@@ -40,6 +40,7 @@ suite("query90") {
          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_90 '''
     explain shape plan
diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query91.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query91.groovy
index 6200e5a771dcd2..bad3d75039816d 100644
--- a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query91.groovy
+++ b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query91.groovy
@@ -40,6 +40,7 @@ suite("query91") {
          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_91 '''
     explain shape plan
diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query92.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query92.groovy
index 3acbd70e06e7cc..56e470d1652394 100644
--- a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query92.groovy
+++ b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query92.groovy
@@ -40,6 +40,7 @@ suite("query92") {
          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_92 '''
     explain shape plan
diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query93.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query93.groovy
index ae815dc45d246d..a1074c8ea52cdd 100644
--- a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query93.groovy
+++ b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query93.groovy
@@ -40,6 +40,7 @@ suite("query93") {
          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_93 '''
     explain shape plan
diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query94.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query94.groovy
index da1b1a0f9c3c8d..48ff5e3da213e4 100644
--- a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query94.groovy
+++ b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query94.groovy
@@ -40,6 +40,7 @@ suite("query94") {
          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_94 '''
     explain shape plan
diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query95.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query95.groovy
index 0e44b59ae8ae45..78c4d0e81df3dd 100644
--- a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query95.groovy
+++ b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query95.groovy
@@ -40,6 +40,7 @@ suite("query95") {
          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_95 '''
     explain shape plan
diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query96.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query96.groovy
index abbc23ef7e4fda..148908951723b3 100644
--- a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query96.groovy
+++ b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query96.groovy
@@ -40,6 +40,7 @@ suite("query96") {
          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_96 '''
     explain shape plan
diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query97.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query97.groovy
index f31c2acccb667d..10dd934df3fa0a 100644
--- a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query97.groovy
+++ b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query97.groovy
@@ -40,6 +40,7 @@ suite("query97") {
          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_97 '''
     explain shape plan
diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query98.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query98.groovy
index 57171bdba0340f..be1b13c320a7bd 100644
--- a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query98.groovy
+++ b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query98.groovy
@@ -40,6 +40,7 @@ suite("query98") {
          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_98 '''
     explain shape plan
diff --git a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query99.groovy b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query99.groovy
index 93e2a0a057ff27..fe6a2ea601ca61 100644
--- a/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query99.groovy
+++ b/regression-test/suites/nereids_tpcds_shape_sf10t_orc/shape/query99.groovy
@@ -40,6 +40,7 @@ suite("query99") {
          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_99 '''
     explain shape plan