diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/processor/post/MergeProjectPostProcessor.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/processor/post/MergeProjectPostProcessor.java index 4a5ad492435403..1c465cb790d544 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/nereids/processor/post/MergeProjectPostProcessor.java +++ b/fe/fe-core/src/main/java/org/apache/doris/nereids/processor/post/MergeProjectPostProcessor.java @@ -37,8 +37,12 @@ public PhysicalProject visitPhysicalProject(PhysicalProject proj Plan newChild = child.accept(this, ctx); if (newChild instanceof PhysicalProject) { List projections = project.mergeProjections((PhysicalProject) newChild); - return project.withProjectionsAndChild(projections, newChild.child(0)); + return (PhysicalProject) project + .withProjectionsAndChild(projections, newChild.child(0)) + .copyStatsAndGroupIdFrom(project); } - return child != newChild ? project.withChildren(Lists.newArrayList(newChild)) : project; + return child != newChild + ? (PhysicalProject) project.withChildren(Lists.newArrayList(newChild)).copyStatsAndGroupIdFrom(project) + : project; } } diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/processor/post/PlanPostProcessors.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/processor/post/PlanPostProcessors.java index 787be605db132f..9ae4c55608b765 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/nereids/processor/post/PlanPostProcessors.java +++ b/fe/fe-core/src/main/java/org/apache/doris/nereids/processor/post/PlanPostProcessors.java @@ -61,6 +61,7 @@ public List getProcessors() { builder.add(new PushdownFilterThroughProject()); builder.add(new MergeProjectPostProcessor()); builder.add(new RecomputeLogicalPropertiesProcessor()); + builder.add(new TopNScanOpt()); // after generate rf, DO NOT replace PLAN NODE builder.add(new FragmentProcessor()); if (!cascadesContext.getConnectContext().getSessionVariable().getRuntimeFilterMode() @@ -71,7 +72,6 @@ public List getProcessors() { } } builder.add(new Validator()); - builder.add(new TopNScanOpt()); return builder.build(); } } diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/processor/post/PushdownFilterThroughProject.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/processor/post/PushdownFilterThroughProject.java index 3eba798acbf162..b5f269b069596e 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/nereids/processor/post/PushdownFilterThroughProject.java +++ b/fe/fe-core/src/main/java/org/apache/doris/nereids/processor/post/PushdownFilterThroughProject.java @@ -19,6 +19,7 @@ import org.apache.doris.nereids.CascadesContext; import org.apache.doris.nereids.trees.plans.Plan; +import org.apache.doris.nereids.trees.plans.physical.AbstractPhysicalPlan; import org.apache.doris.nereids.trees.plans.physical.PhysicalFilter; import org.apache.doris.nereids.trees.plans.physical.PhysicalProject; import org.apache.doris.nereids.util.ExpressionUtils; @@ -31,14 +32,20 @@ public class PushdownFilterThroughProject extends PlanPostProcessor { public Plan visitPhysicalFilter(PhysicalFilter filter, CascadesContext context) { Plan child = filter.child(); if (!(child instanceof PhysicalProject)) { - return filter.withChildren(child.accept(this, context)); + Plan newChild = child.accept(this, context); + if (newChild == child) { + return filter; + } else { + return ((AbstractPhysicalPlan) filter.withChildren(child.accept(this, context))) + .copyStatsAndGroupIdFrom(filter); + } } PhysicalProject project = (PhysicalProject) child; PhysicalFilter newFilter = filter.withConjunctsAndChild( ExpressionUtils.replace(filter.getConjuncts(), project.getAliasToProducer()), project.child()); - - return project.withChildren(newFilter.accept(this, context)); + return ((PhysicalProject) project.withChildren(newFilter.accept(this, context))) + .copyStatsAndGroupIdFrom(project); } } diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/processor/post/RecomputeLogicalPropertiesProcessor.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/processor/post/RecomputeLogicalPropertiesProcessor.java index 08b9132b0ca346..97786684de02db 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/nereids/processor/post/RecomputeLogicalPropertiesProcessor.java +++ b/fe/fe-core/src/main/java/org/apache/doris/nereids/processor/post/RecomputeLogicalPropertiesProcessor.java @@ -18,10 +18,8 @@ package org.apache.doris.nereids.processor.post; import org.apache.doris.nereids.CascadesContext; -import org.apache.doris.nereids.trees.plans.AbstractPlan; import org.apache.doris.nereids.trees.plans.Plan; -import org.apache.doris.nereids.trees.plans.physical.PhysicalPlan; -import org.apache.doris.nereids.util.MutableState; +import org.apache.doris.nereids.trees.plans.physical.AbstractPhysicalPlan; /** * merge consecutive projects @@ -29,11 +27,8 @@ public class RecomputeLogicalPropertiesProcessor extends PlanPostProcessor { @Override public Plan visit(Plan plan, CascadesContext ctx) { - PhysicalPlan physicalPlan = (PhysicalPlan) visitChildren(this, plan, ctx); - physicalPlan = physicalPlan.resetLogicalProperties(); - physicalPlan = physicalPlan.withPhysicalPropertiesAndStats(physicalPlan.getPhysicalProperties(), - ((AbstractPlan) plan).getStats()); - physicalPlan.setMutableState(MutableState.KEY_GROUP, plan.getGroupIdAsString()); - return physicalPlan; + AbstractPhysicalPlan newPlan = (AbstractPhysicalPlan) visitChildren(this, plan, ctx); + return ((AbstractPhysicalPlan) newPlan.resetLogicalProperties()) + .copyStatsAndGroupIdFrom((AbstractPhysicalPlan) plan); } } diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/processor/post/TopNScanOpt.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/processor/post/TopNScanOpt.java index b221570edf180a..2ca1380d1b050f 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/nereids/processor/post/TopNScanOpt.java +++ b/fe/fe-core/src/main/java/org/apache/doris/nereids/processor/post/TopNScanOpt.java @@ -44,7 +44,7 @@ public PhysicalTopN visitPhysicalTopN(PhysicalTopN rewrittenTopN = rewriteTopN(topN.getPhysicalTopN()); if (topN.getPhysicalTopN() != rewrittenTopN) { - topN = topN.withPhysicalTopN(rewrittenTopN); + topN = topN.withPhysicalTopN(rewrittenTopN).copyStatsAndGroupIdFrom(topN); } return topN; } @@ -103,7 +103,7 @@ private PhysicalTopN rewriteTopN(PhysicalTopN to olapScan = (OlapScan) child; if (olapScan.getTable().isDupKeysOrMergeOnWrite()) { - return topN.withEnableRuntimeFilter(true); + return topN.withEnableRuntimeFilter(true).copyStatsAndGroupIdFrom(topN); } return topN; diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/physical/AbstractPhysicalPlan.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/physical/AbstractPhysicalPlan.java index 225f0f0dc62b1b..783d3749019876 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/physical/AbstractPhysicalPlan.java +++ b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/physical/AbstractPhysicalPlan.java @@ -32,6 +32,7 @@ import org.apache.doris.nereids.trees.plans.Explainable; import org.apache.doris.nereids.trees.plans.Plan; import org.apache.doris.nereids.trees.plans.PlanType; +import org.apache.doris.nereids.util.MutableState; import org.apache.doris.planner.RuntimeFilterId; import org.apache.doris.qe.ConnectContext; import org.apache.doris.statistics.Statistics; @@ -136,4 +137,11 @@ public boolean pushDownRuntimeFilter(CascadesContext context, IdGenerator T copyStatsAndGroupIdFrom(T from) { + T newPlan = (T) withPhysicalPropertiesAndStats( + from.getPhysicalProperties(), from.getStats()); + newPlan.setMutableState(MutableState.KEY_GROUP, from.getGroupIdAsString()); + return newPlan; + } } diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/SessionVariable.java b/fe/fe-core/src/main/java/org/apache/doris/qe/SessionVariable.java index 2df47f1e9ad581..94947cd60f365e 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/qe/SessionVariable.java +++ b/fe/fe-core/src/main/java/org/apache/doris/qe/SessionVariable.java @@ -904,7 +904,7 @@ public void setMaxJoinNumberOfReorder(int maxJoinNumberOfReorder) { private double broadcastHashtableMemLimitPercentage = 0.2; @VariableMgr.VarAttr(name = ENABLE_RUNTIME_FILTER_PRUNE, needForward = true) - public boolean enableRuntimeFilterPrune = false; + public boolean enableRuntimeFilterPrune = true; /** * The client can pass some special information by setting this session variable in the format: "k1:v1;k2:v2". diff --git a/fe/fe-core/src/test/java/org/apache/doris/nereids/postprocess/RuntimeFilterTest.java b/fe/fe-core/src/test/java/org/apache/doris/nereids/postprocess/RuntimeFilterTest.java index a2f9b15ac483a2..17b8c53fa88ef1 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/nereids/postprocess/RuntimeFilterTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/nereids/postprocess/RuntimeFilterTest.java @@ -45,6 +45,8 @@ public void runBeforeAll() throws Exception { super.runBeforeAll(); connectContext.getSessionVariable().setRuntimeFilterMode("Global"); connectContext.getSessionVariable().setRuntimeFilterType(8); + connectContext.getSessionVariable().setEnableRuntimeFilterPrune(false); + connectContext.getSessionVariable().expandRuntimeFilterByInnerJoin = false; } @Test diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/ddl/rf.tmpl b/regression-test/suites/nereids_tpcds_shape_sf100_p0/ddl/rf.tmpl index 9c16ff65f29810..de7d37d18394de 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/ddl/rf.tmpl +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/ddl/rf.tmpl @@ -30,6 +30,7 @@ suite("ds_rf{--}") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' String stmt = ''' explain physical plan {query} diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf1.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf1.groovy index 6218bb5be04cf4..289caf18639dcf 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf1.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf1.groovy @@ -30,6 +30,8 @@ suite("ds_rf1") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan with customer_total_return as diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf10.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf10.groovy index 124c3be5d6df24..e7e12b93788e8e 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf10.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf10.groovy @@ -30,6 +30,8 @@ suite("ds_rf10") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan select diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf11.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf11.groovy index 972ab87d7a7d3b..3e9dcab395fd37 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf11.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf11.groovy @@ -30,6 +30,8 @@ suite("ds_rf11") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan with year_total as ( diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf12.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf12.groovy index c610e21b6076d7..4abe8f4bf3a778 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf12.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf12.groovy @@ -30,6 +30,8 @@ suite("ds_rf12") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan select i_item_id diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf13.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf13.groovy index 4f302dd6145e62..8a6479ba739f13 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf13.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf13.groovy @@ -30,6 +30,8 @@ suite("ds_rf13") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan select avg(ss_quantity) diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf14.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf14.groovy index d83496ff6498b0..0b90f604cd063d 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf14.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf14.groovy @@ -30,6 +30,8 @@ suite("ds_rf14") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan with cross_items as diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf15.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf15.groovy index 117705e0828dff..df87e7eca804de 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf15.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf15.groovy @@ -30,6 +30,8 @@ suite("ds_rf15") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan select ca_zip diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf16.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf16.groovy index dadcc356c135d6..e15da778854f5c 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf16.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf16.groovy @@ -30,6 +30,8 @@ suite("ds_rf16") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan select diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf17.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf17.groovy index a0ec1492fdec5f..bb61a205c3bb32 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf17.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf17.groovy @@ -30,6 +30,8 @@ suite("ds_rf17") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan select i_item_id diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf18.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf18.groovy index 05c0fcb69d42cb..76e44365acd7ec 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf18.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf18.groovy @@ -30,6 +30,8 @@ suite("ds_rf18") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan select i_item_id, diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf19.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf19.groovy index 231ba294bca224..7bbad11ef5cd18 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf19.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf19.groovy @@ -30,6 +30,8 @@ suite("ds_rf19") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan select i_brand_id brand_id, i_brand brand, i_manufact_id, i_manufact, diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf2.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf2.groovy index 255be66dbbfea8..a7b6155cc21a78 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf2.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf2.groovy @@ -30,6 +30,8 @@ suite("ds_rf2") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan with wscs as diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf20.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf20.groovy index bf8c928f0c4c2f..802adab15a7b0c 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf20.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf20.groovy @@ -30,6 +30,8 @@ suite("ds_rf20") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan select i_item_id diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf21.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf21.groovy index d92daea3a2134e..ca29142dcc825c 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf21.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf21.groovy @@ -30,6 +30,8 @@ suite("ds_rf21") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan select * diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf22.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf22.groovy index e5a41b64ebad3e..dd11e7e2671d1f 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf22.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf22.groovy @@ -30,6 +30,8 @@ suite("ds_rf22") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan select i_product_name diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf23.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf23.groovy index 39d1987ecd9d31..0984f4df1104d5 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf23.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf23.groovy @@ -30,6 +30,8 @@ suite("ds_rf23") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan with frequent_ss_items as diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf24.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf24.groovy index 4047b407b3f34a..5d34c892b0541b 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf24.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf24.groovy @@ -30,6 +30,8 @@ suite("ds_rf24") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan with ssales as diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf25.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf25.groovy index ecede80079b435..75c228b8a24a22 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf25.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf25.groovy @@ -30,6 +30,8 @@ suite("ds_rf25") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan select diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf26.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf26.groovy index 9f3cbaebb46e03..9b4ba4a8356623 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf26.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf26.groovy @@ -30,6 +30,8 @@ suite("ds_rf26") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan select i_item_id, diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf27.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf27.groovy index ffdc78da1ed0ae..7fc17b07f0678a 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf27.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf27.groovy @@ -30,6 +30,8 @@ suite("ds_rf27") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan select i_item_id, diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf28.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf28.groovy index 2ef32fdac41e9b..705561e3943f01 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf28.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf28.groovy @@ -30,6 +30,8 @@ suite("ds_rf28") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan select * diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf29.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf29.groovy index 1f0e968c517eeb..42a00e2fb0d806 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf29.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf29.groovy @@ -30,6 +30,8 @@ suite("ds_rf29") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan select diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf3.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf3.groovy index 216be9f09eec4c..1a179bf54346c6 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf3.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf3.groovy @@ -30,6 +30,8 @@ suite("ds_rf3") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan select dt.d_year diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf30.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf30.groovy index 65724117c8f132..f7dcbe091913ad 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf30.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf30.groovy @@ -30,6 +30,8 @@ suite("ds_rf30") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan with customer_total_return as diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf31.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf31.groovy index b3da12ed061d61..26a64a16666022 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf31.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf31.groovy @@ -30,6 +30,8 @@ suite("ds_rf31") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan with ss as diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf32.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf32.groovy index 576df6a87738a6..63d9c4ea83f32c 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf32.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf32.groovy @@ -30,6 +30,8 @@ suite("ds_rf32") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan select sum(cs_ext_discount_amt) as "excess discount amount" diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf33.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf33.groovy index c9c44210696677..b979714ccd6f6d 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf33.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf33.groovy @@ -30,6 +30,8 @@ suite("ds_rf33") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan with ss as ( diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf34.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf34.groovy index 978e7bf6db2f89..01eb27f7954871 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf34.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf34.groovy @@ -30,6 +30,8 @@ suite("ds_rf34") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan select c_last_name diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf35.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf35.groovy index d4110b005ce1c1..620b0970e02a20 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf35.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf35.groovy @@ -30,6 +30,8 @@ suite("ds_rf35") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan select diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf36.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf36.groovy index be9a4d57c2a343..d25242f23a5787 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf36.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf36.groovy @@ -30,6 +30,8 @@ suite("ds_rf36") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan select diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf37.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf37.groovy index 53a78e727f7c60..8869995ddd04ec 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf37.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf37.groovy @@ -30,6 +30,8 @@ suite("ds_rf37") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan select i_item_id diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf38.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf38.groovy index 35d4435265835e..a609d87ad1e75a 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf38.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf38.groovy @@ -30,6 +30,8 @@ suite("ds_rf38") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan select count(*) from ( diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf39.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf39.groovy index ca12fdd1928976..bd696286027cd9 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf39.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf39.groovy @@ -30,6 +30,8 @@ suite("ds_rf39") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan with inv as diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf4.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf4.groovy index cd9cee0cef5a2e..02998649b45b64 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf4.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf4.groovy @@ -30,6 +30,8 @@ suite("ds_rf4") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan with year_total as ( diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf40.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf40.groovy index 96a557b9f6b10a..5414b93cb9d857 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf40.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf40.groovy @@ -30,6 +30,8 @@ suite("ds_rf40") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan select diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf41.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf41.groovy index e931f532fde16e..77637a7b8b2d03 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf41.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf41.groovy @@ -30,6 +30,8 @@ suite("ds_rf41") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan select distinct(i_product_name) diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf42.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf42.groovy index 3509fe46e1416a..1eb73d69a1e5a7 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf42.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf42.groovy @@ -30,6 +30,8 @@ suite("ds_rf42") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan select dt.d_year diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf43.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf43.groovy index f1f43102a14a44..f07a996f768ee0 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf43.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf43.groovy @@ -30,6 +30,8 @@ suite("ds_rf43") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan select s_store_name, s_store_id, diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf44.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf44.groovy index 7e6ddb64b9cbb0..07c00fd6816c36 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf44.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf44.groovy @@ -30,6 +30,8 @@ suite("ds_rf44") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan select asceding.rnk, i1.i_product_name best_performing, i2.i_product_name worst_performing diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf45.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf45.groovy index 44343e3fee4eaf..042868ff226ea3 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf45.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf45.groovy @@ -30,6 +30,8 @@ suite("ds_rf45") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan select ca_zip, ca_city, sum(ws_sales_price) diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf46.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf46.groovy index 983a312b0aca14..9fb9712a21d53e 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf46.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf46.groovy @@ -30,6 +30,8 @@ suite("ds_rf46") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan select c_last_name diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf47.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf47.groovy index 69a99bdcc6647b..b6de6acf252361 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf47.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf47.groovy @@ -30,6 +30,8 @@ suite("ds_rf47") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan with v1 as( diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf48.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf48.groovy index 71f514a0f55e62..a49a2af3183212 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf48.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf48.groovy @@ -30,6 +30,8 @@ suite("ds_rf48") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan select sum (ss_quantity) diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf49.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf49.groovy index 7f89351feac948..9ea2f27d4e24d6 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf49.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf49.groovy @@ -30,6 +30,8 @@ suite("ds_rf49") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan select channel, item, return_ratio, return_rank, currency_rank from diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf5.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf5.groovy index 9d7942f8f787b1..3ac376e4cbc491 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf5.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf5.groovy @@ -30,6 +30,8 @@ suite("ds_rf5") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan with ssr as diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf50.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf50.groovy index 99ae46e0718c9f..2e107e4893f161 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf50.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf50.groovy @@ -30,6 +30,8 @@ suite("ds_rf50") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan select diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf51.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf51.groovy index 512a10bc9d58c2..54682f63c70c77 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf51.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf51.groovy @@ -30,6 +30,8 @@ suite("ds_rf51") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan WITH web_v1 as ( diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf52.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf52.groovy index e56a71c0664a29..75940a51b38b7b 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf52.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf52.groovy @@ -30,6 +30,8 @@ suite("ds_rf52") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan select dt.d_year diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf53.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf53.groovy index 47142102dcabaa..5e7a32194ad70e 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf53.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf53.groovy @@ -30,6 +30,8 @@ suite("ds_rf53") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan select * from diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf54.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf54.groovy index 88431716efc10d..f75ee0d02ae37b 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf54.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf54.groovy @@ -30,6 +30,8 @@ suite("ds_rf54") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan with my_customers as ( diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf55.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf55.groovy index 247038317b128a..3d148e731e6acb 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf55.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf55.groovy @@ -30,6 +30,8 @@ suite("ds_rf55") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan select i_brand_id brand_id, i_brand brand, diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf56.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf56.groovy index ef8d218104f158..31750145181bb5 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf56.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf56.groovy @@ -30,6 +30,8 @@ suite("ds_rf56") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan with ss as ( diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf57.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf57.groovy index b9d3fbe6dedb3e..384c2d4a13b305 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf57.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf57.groovy @@ -30,6 +30,8 @@ suite("ds_rf57") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan with v1 as( diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf58.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf58.groovy index 4c937338e72e8e..93f40317d0416a 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf58.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf58.groovy @@ -30,6 +30,8 @@ suite("ds_rf58") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan with ss_items as diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf59.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf59.groovy index af6fea1f90cc61..abecbdcd0ad44f 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf59.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf59.groovy @@ -30,6 +30,8 @@ suite("ds_rf59") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan with wss as diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf6.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf6.groovy index d0ca9e11f58c6a..7a01a6706df151 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf6.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf6.groovy @@ -30,6 +30,8 @@ suite("ds_rf6") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan select a.ca_state state, count(*) cnt diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf60.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf60.groovy index 96d5edec07c3da..c91fbb2c021534 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf60.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf60.groovy @@ -30,6 +30,8 @@ suite("ds_rf60") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan with ss as ( diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf61.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf61.groovy index f567f8c0775012..722fc56a5ec2b2 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf61.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf61.groovy @@ -30,6 +30,8 @@ suite("ds_rf61") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan select promotions,total,cast(promotions as decimal(15,4))/cast(total as decimal(15,4))*100 diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf62.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf62.groovy index 06ee4e2ec78e4e..9e28fbf7b3fd15 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf62.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf62.groovy @@ -30,6 +30,8 @@ suite("ds_rf62") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan select diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf63.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf63.groovy index f8b4f3d893d99f..9b093dafa28a22 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf63.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf63.groovy @@ -30,6 +30,8 @@ suite("ds_rf63") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan select * diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf64.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf64.groovy index 51940e2b51fd2d..683de7345135d1 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf64.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf64.groovy @@ -30,6 +30,8 @@ suite("ds_rf64") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan with cs_ui as diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf65.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf65.groovy index b7a5e2fb273963..d475614491f771 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf65.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf65.groovy @@ -30,6 +30,8 @@ suite("ds_rf65") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan select diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf66.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf66.groovy index fcd2b464dfe65f..bfa158d5c073c3 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf66.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf66.groovy @@ -30,6 +30,8 @@ suite("ds_rf66") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan select diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf67.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf67.groovy index 063f8f37acb4b8..aea9206edac898 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf67.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf67.groovy @@ -30,6 +30,8 @@ suite("ds_rf67") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan select * diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf68.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf68.groovy index 6ee1d11899d93a..9d5b9d48b0a38d 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf68.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf68.groovy @@ -30,6 +30,8 @@ suite("ds_rf68") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan select c_last_name diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf69.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf69.groovy index f2cfedf9d68c86..b4bea33b9a04f4 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf69.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf69.groovy @@ -30,6 +30,8 @@ suite("ds_rf69") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan select diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf7.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf7.groovy index c5b09f74070714..fad69d7dda952d 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf7.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf7.groovy @@ -30,6 +30,8 @@ suite("ds_rf7") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan select i_item_id, diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf70.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf70.groovy index 41245523d82f97..a059ef6ae93d6b 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf70.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf70.groovy @@ -30,6 +30,8 @@ suite("ds_rf70") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan select diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf71.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf71.groovy index ac19b330fa9139..4c6ba1d05fd05d 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf71.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf71.groovy @@ -30,6 +30,8 @@ suite("ds_rf71") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan select i_brand_id brand_id, i_brand brand,t_hour,t_minute, diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf72.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf72.groovy index df86fa05c0cd63..92e1660cce530b 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf72.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf72.groovy @@ -30,6 +30,8 @@ suite("ds_rf72") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan select i_item_desc diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf73.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf73.groovy index cee6c57122ffe8..456b4a8b79e5aa 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf73.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf73.groovy @@ -30,6 +30,8 @@ suite("ds_rf73") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan select c_last_name diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf74.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf74.groovy index 75ed33223b0991..630152cfd6506a 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf74.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf74.groovy @@ -30,6 +30,8 @@ suite("ds_rf74") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan with year_total as ( diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf75.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf75.groovy index 23ea01d3a54b2c..41b8d8d8837ecc 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf75.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf75.groovy @@ -30,6 +30,8 @@ suite("ds_rf75") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan WITH all_sales AS ( diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf76.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf76.groovy index ab820977029219..fcc064857d348a 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf76.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf76.groovy @@ -30,6 +30,8 @@ suite("ds_rf76") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan select channel, col_name, d_year, d_qoy, i_category, COUNT(*) sales_cnt, SUM(ext_sales_price) sales_amt FROM ( diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf77.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf77.groovy index ebe3f3f7b2352a..99b6a38b456268 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf77.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf77.groovy @@ -30,6 +30,8 @@ suite("ds_rf77") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan with ss as diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf78.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf78.groovy index 4eabc54415d848..6c4549151cae44 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf78.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf78.groovy @@ -30,6 +30,8 @@ suite("ds_rf78") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan with ws as diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf79.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf79.groovy index 6d5fe6967e7d9c..e45a6a11ba8bff 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf79.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf79.groovy @@ -30,6 +30,8 @@ suite("ds_rf79") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan select diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf8.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf8.groovy index e049568c92c41e..3765f283426748 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf8.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf8.groovy @@ -30,6 +30,8 @@ suite("ds_rf8") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan select s_store_name diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf80.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf80.groovy index 739fbb942ccb00..a41bdd43564f02 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf80.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf80.groovy @@ -30,6 +30,8 @@ suite("ds_rf80") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan with ssr as diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf81.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf81.groovy index 77d4fb0b875b92..1309fede04c19e 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf81.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf81.groovy @@ -30,6 +30,8 @@ suite("ds_rf81") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan with customer_total_return as diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf82.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf82.groovy index f996c6bc61af57..7144fe13c98a21 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf82.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf82.groovy @@ -30,6 +30,8 @@ suite("ds_rf82") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan select i_item_id diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf83.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf83.groovy index 6a9424e457795d..51be93e93941ae 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf83.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf83.groovy @@ -30,6 +30,8 @@ suite("ds_rf83") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan with sr_items as diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf84.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf84.groovy index 1454f752e2cdac..23c0d7a2f1f20f 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf84.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf84.groovy @@ -30,6 +30,8 @@ suite("ds_rf84") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan select c_customer_id as customer_id diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf85.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf85.groovy index b716a2a89d246d..9f5999c833ff10 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf85.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf85.groovy @@ -30,6 +30,8 @@ suite("ds_rf85") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan select substr(r_reason_desc,1,20) diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf86.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf86.groovy index 4b14c597f9baae..b2bc785d82da81 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf86.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf86.groovy @@ -30,6 +30,8 @@ suite("ds_rf86") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan select diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf87.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf87.groovy index 79b6c1f7387740..667c04af0242a1 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf87.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf87.groovy @@ -30,6 +30,8 @@ suite("ds_rf87") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan select count(*) diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf88.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf88.groovy index e3a859ccc8c767..b33e94c632615e 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf88.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf88.groovy @@ -30,6 +30,8 @@ suite("ds_rf88") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan select * diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf89.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf89.groovy index 56ff92bfbcbfbf..10959909109229 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf89.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf89.groovy @@ -30,6 +30,8 @@ suite("ds_rf89") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan select * diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf9.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf9.groovy index c43bab96ffac1d..a57d6f5a848711 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf9.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf9.groovy @@ -30,6 +30,8 @@ suite("ds_rf9") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan select case when (select count(*) diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf90.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf90.groovy index d7f99b5ff66fac..eae00c6c9863eb 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf90.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf90.groovy @@ -30,6 +30,8 @@ suite("ds_rf90") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan select cast(amc as decimal(15,4))/cast(pmc as decimal(15,4)) am_pm_ratio diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf91.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf91.groovy index 8145425acdfae3..a0a1ec8fe7b0b6 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf91.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf91.groovy @@ -30,6 +30,8 @@ suite("ds_rf91") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan select diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf92.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf92.groovy index 29ea53baca84e4..ad8dc98d631331 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf92.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf92.groovy @@ -30,6 +30,8 @@ suite("ds_rf92") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan select diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf93.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf93.groovy index 0b53b5f408a68c..5cfc60f9ff5b75 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf93.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf93.groovy @@ -30,6 +30,8 @@ suite("ds_rf93") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan select ss_customer_sk diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf94.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf94.groovy index 73bc55ffbcc2a1..4eb9be1526165a 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf94.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf94.groovy @@ -30,6 +30,8 @@ suite("ds_rf94") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan select diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf95.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf95.groovy index 689c0467102c9d..97e10cd2fc2e9a 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf95.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf95.groovy @@ -30,6 +30,8 @@ suite("ds_rf95") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan with ws_wh as diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf96.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf96.groovy index 204fb9edfc0df3..5253b27a899e86 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf96.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf96.groovy @@ -30,6 +30,8 @@ suite("ds_rf96") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan select count(*) diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf97.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf97.groovy index 8c5c1c1bf9a6bd..65959ecab9ea68 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf97.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf97.groovy @@ -30,6 +30,8 @@ suite("ds_rf97") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan with ssci as ( diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf98.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf98.groovy index 9179f7ab4f95c9..18dea27438489a 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf98.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf98.groovy @@ -30,6 +30,8 @@ suite("ds_rf98") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan select i_item_id diff --git a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf99.groovy b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf99.groovy index 4f627fb721552d..9999be39541cc8 100644 --- a/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf99.groovy +++ b/regression-test/suites/nereids_tpcds_shape_sf100_p0/rf/ds_rf99.groovy @@ -30,6 +30,8 @@ suite("ds_rf99") { sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan select diff --git a/regression-test/suites/nereids_tpch_shape_sf1000_p0/ddl/rf.tmpl b/regression-test/suites/nereids_tpch_shape_sf1000_p0/ddl/rf.tmpl index 21010ec4ee0b24..feb99537035da2 100644 --- a/regression-test/suites/nereids_tpch_shape_sf1000_p0/ddl/rf.tmpl +++ b/regression-test/suites/nereids_tpch_shape_sf1000_p0/ddl/rf.tmpl @@ -29,6 +29,9 @@ suite("h_rf{--}") { sql 'set forbid_unknown_col_stats=true' sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' + sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan diff --git a/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf1.groovy b/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf1.groovy index b798e3c1193c5d..81c2b9ca1f157f 100644 --- a/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf1.groovy +++ b/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf1.groovy @@ -29,6 +29,9 @@ suite("h_rf1") { sql 'set forbid_unknown_col_stats=true' sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' + sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan diff --git a/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf10.groovy b/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf10.groovy index 60b208e7fdf675..e92e31dfef0d5e 100644 --- a/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf10.groovy +++ b/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf10.groovy @@ -29,6 +29,9 @@ suite("h_rf10") { sql 'set forbid_unknown_col_stats=true' sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' + sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan diff --git a/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf11.groovy b/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf11.groovy index 98979272b33d53..e272dbb2a60f8d 100644 --- a/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf11.groovy +++ b/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf11.groovy @@ -29,6 +29,9 @@ suite("h_rf11") { sql 'set forbid_unknown_col_stats=true' sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' + sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan diff --git a/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf12.groovy b/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf12.groovy index 2561f76cd760b1..66866e1a003235 100644 --- a/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf12.groovy +++ b/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf12.groovy @@ -29,6 +29,9 @@ suite("h_rf12") { sql 'set forbid_unknown_col_stats=true' sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' + sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan diff --git a/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf13.groovy b/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf13.groovy index 3ea24d8f14498e..1820786da0b6d6 100644 --- a/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf13.groovy +++ b/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf13.groovy @@ -29,6 +29,9 @@ suite("h_rf13") { sql 'set forbid_unknown_col_stats=true' sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' + sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan diff --git a/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf14.groovy b/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf14.groovy index d7d0743b45d73a..58ed949bd1ffac 100644 --- a/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf14.groovy +++ b/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf14.groovy @@ -29,6 +29,9 @@ suite("h_rf14") { sql 'set forbid_unknown_col_stats=true' sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' + sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan diff --git a/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf15.groovy b/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf15.groovy index b8324f83116c1e..7f795350b8f939 100644 --- a/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf15.groovy +++ b/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf15.groovy @@ -29,6 +29,9 @@ suite("h_rf15") { sql 'set forbid_unknown_col_stats=true' sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' + sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan diff --git a/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf16.groovy b/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf16.groovy index 614836609f7a20..c2c9364d33dd4b 100644 --- a/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf16.groovy +++ b/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf16.groovy @@ -29,6 +29,9 @@ suite("h_rf16") { sql 'set forbid_unknown_col_stats=true' sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' + sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan diff --git a/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf17.groovy b/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf17.groovy index ec15e306de67bb..61039d3d5483c9 100644 --- a/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf17.groovy +++ b/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf17.groovy @@ -29,6 +29,9 @@ suite("h_rf17") { sql 'set forbid_unknown_col_stats=true' sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' + sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan diff --git a/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf18.groovy b/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf18.groovy index 31ee643b8fc565..2ba80c7caff2be 100644 --- a/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf18.groovy +++ b/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf18.groovy @@ -29,6 +29,9 @@ suite("h_rf18") { sql 'set forbid_unknown_col_stats=true' sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' + sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan diff --git a/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf19.groovy b/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf19.groovy index 594168a3fbca88..d49e52979083cb 100644 --- a/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf19.groovy +++ b/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf19.groovy @@ -29,6 +29,9 @@ suite("h_rf19") { sql 'set forbid_unknown_col_stats=true' sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' + sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan diff --git a/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf2.groovy b/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf2.groovy index 6f04945edc0953..2a014e67d12955 100644 --- a/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf2.groovy +++ b/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf2.groovy @@ -29,6 +29,9 @@ suite("h_rf2") { sql 'set forbid_unknown_col_stats=true' sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' + sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan diff --git a/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf20.groovy b/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf20.groovy index 07f34f943921b0..d88543c1ff65a2 100644 --- a/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf20.groovy +++ b/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf20.groovy @@ -29,6 +29,9 @@ suite("h_rf20") { sql 'set forbid_unknown_col_stats=true' sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' + sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan diff --git a/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf21.groovy b/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf21.groovy index 933f66c1df50e4..34da1d1deabb24 100644 --- a/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf21.groovy +++ b/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf21.groovy @@ -29,6 +29,9 @@ suite("h_rf21") { sql 'set forbid_unknown_col_stats=true' sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' + sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan diff --git a/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf22.groovy b/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf22.groovy index e67319429d62a6..54016fe020a973 100644 --- a/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf22.groovy +++ b/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf22.groovy @@ -29,6 +29,9 @@ suite("h_rf22") { sql 'set forbid_unknown_col_stats=true' sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' + sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan diff --git a/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf3.groovy b/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf3.groovy index fe08dd277cc751..924d8b8c9b4e75 100644 --- a/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf3.groovy +++ b/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf3.groovy @@ -29,6 +29,9 @@ suite("h_rf3") { sql 'set forbid_unknown_col_stats=true' sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' + sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan diff --git a/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf4.groovy b/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf4.groovy index 32993b7b73dee1..fcf125ce4b0046 100644 --- a/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf4.groovy +++ b/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf4.groovy @@ -29,6 +29,9 @@ suite("h_rf4") { sql 'set forbid_unknown_col_stats=true' sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' + sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan diff --git a/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf5.groovy b/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf5.groovy index 045b6fb62d9e23..dabcb2b481b9a4 100644 --- a/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf5.groovy +++ b/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf5.groovy @@ -29,6 +29,9 @@ suite("h_rf5") { sql 'set forbid_unknown_col_stats=true' sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' + sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan diff --git a/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf6.groovy b/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf6.groovy index c53f51918f8646..9aa90460186db4 100644 --- a/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf6.groovy +++ b/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf6.groovy @@ -29,6 +29,9 @@ suite("h_rf6") { sql 'set forbid_unknown_col_stats=true' sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' + sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan diff --git a/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf7.groovy b/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf7.groovy index 283f75263ef77b..02a6d4f85715bf 100644 --- a/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf7.groovy +++ b/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf7.groovy @@ -29,6 +29,9 @@ suite("h_rf7") { sql 'set forbid_unknown_col_stats=true' sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' + sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan diff --git a/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf8.groovy b/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf8.groovy index 76d0eec9938694..f42a8a6e1503dc 100644 --- a/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf8.groovy +++ b/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf8.groovy @@ -29,6 +29,9 @@ suite("h_rf8") { sql 'set forbid_unknown_col_stats=true' sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' + sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan diff --git a/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf9.groovy b/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf9.groovy index 7044e5fab4613c..856eda2aed5314 100644 --- a/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf9.groovy +++ b/regression-test/suites/nereids_tpch_shape_sf1000_p0/rf/h_rf9.groovy @@ -29,6 +29,9 @@ suite("h_rf9") { sql 'set forbid_unknown_col_stats=true' sql 'set broadcast_row_count_limit = 30000000' sql 'set enable_nereids_timeout = false' + sql 'set enable_pipeline_engine=true' + sql 'set enable_runtime_filter_prune=false' + sql 'set expand_runtime_filter_by_inner_join=false' String stmt = ''' explain physical plan