This is an automated email from the ASF dual-hosted git repository.
englefly pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new eb9d334b552 [opt](nereids) enable runtime filter prune by default
(#24717)
eb9d334b552 is described below
commit eb9d334b5522983be8efbb2d7eda0017d4d9cfc3
Author: minghong <[email protected]>
AuthorDate: Fri Sep 22 19:11:10 2023 +0800
[opt](nereids) enable runtime filter prune by default (#24717)
add stats back to physical plan in post processors. stats are used by
rf-prune
set enable_runtime_filter_prune true by default
---
.../processor/post/MergeProjectPostProcessor.java | 8 +++--
.../nereids/processor/post/PlanPostProcessors.java | 2 +-
.../post/PushdownFilterThroughProject.java | 13 +++++--
.../post/RecomputeLogicalPropertiesProcessor.java | 13 +++----
.../doris/nereids/processor/post/TopNScanOpt.java | 8 ++---
.../trees/plans/physical/AbstractPhysicalPlan.java | 8 +++++
.../java/org/apache/doris/qe/SessionVariable.java | 2 +-
.../nereids/postprocess/RuntimeFilterTest.java | 2 ++
.../org/apache/doris/planner/QueryPlanTest.java | 2 +-
.../test_runtimefilter_with_window.groovy | 42 +++++++++++++++++++---
.../nereids_tpcds_shape_sf100_p0/ddl/rf.tmpl | 1 +
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf1.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf10.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf11.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf12.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf13.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf14.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf15.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf16.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf17.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf18.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf19.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf2.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf20.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf21.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf22.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf23.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf24.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf25.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf26.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf27.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf28.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf29.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf3.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf30.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf31.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf32.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf33.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf34.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf35.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf36.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf37.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf38.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf39.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf4.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf40.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf41.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf42.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf43.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf44.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf45.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf46.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf47.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf48.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf49.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf5.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf50.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf51.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf52.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf53.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf54.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf55.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf56.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf57.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf58.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf59.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf6.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf60.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf61.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf62.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf63.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf64.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf65.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf66.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf67.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf68.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf69.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf7.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf70.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf71.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf72.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf73.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf74.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf75.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf76.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf77.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf78.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf79.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf8.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf80.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf81.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf82.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf83.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf84.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf85.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf86.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf87.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf88.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf89.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf9.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf90.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf91.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf92.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf93.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf94.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf95.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf96.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf97.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf98.groovy | 2 ++
.../nereids_tpcds_shape_sf100_p0/rf/ds_rf99.groovy | 2 ++
.../nereids_tpch_shape_sf1000_p0/ddl/rf.tmpl | 3 ++
.../nereids_tpch_shape_sf1000_p0/rf/h_rf1.groovy | 3 ++
.../nereids_tpch_shape_sf1000_p0/rf/h_rf10.groovy | 3 ++
.../nereids_tpch_shape_sf1000_p0/rf/h_rf11.groovy | 3 ++
.../nereids_tpch_shape_sf1000_p0/rf/h_rf12.groovy | 3 ++
.../nereids_tpch_shape_sf1000_p0/rf/h_rf13.groovy | 3 ++
.../nereids_tpch_shape_sf1000_p0/rf/h_rf14.groovy | 3 ++
.../nereids_tpch_shape_sf1000_p0/rf/h_rf15.groovy | 3 ++
.../nereids_tpch_shape_sf1000_p0/rf/h_rf16.groovy | 3 ++
.../nereids_tpch_shape_sf1000_p0/rf/h_rf17.groovy | 3 ++
.../nereids_tpch_shape_sf1000_p0/rf/h_rf18.groovy | 3 ++
.../nereids_tpch_shape_sf1000_p0/rf/h_rf19.groovy | 3 ++
.../nereids_tpch_shape_sf1000_p0/rf/h_rf2.groovy | 3 ++
.../nereids_tpch_shape_sf1000_p0/rf/h_rf20.groovy | 3 ++
.../nereids_tpch_shape_sf1000_p0/rf/h_rf21.groovy | 3 ++
.../nereids_tpch_shape_sf1000_p0/rf/h_rf22.groovy | 3 ++
.../nereids_tpch_shape_sf1000_p0/rf/h_rf3.groovy | 3 ++
.../nereids_tpch_shape_sf1000_p0/rf/h_rf4.groovy | 3 ++
.../nereids_tpch_shape_sf1000_p0/rf/h_rf5.groovy | 3 ++
.../nereids_tpch_shape_sf1000_p0/rf/h_rf6.groovy | 3 ++
.../nereids_tpch_shape_sf1000_p0/rf/h_rf7.groovy | 3 ++
.../nereids_tpch_shape_sf1000_p0/rf/h_rf8.groovy | 3 ++
.../nereids_tpch_shape_sf1000_p0/rf/h_rf9.groovy | 3 ++
133 files changed, 343 insertions(+), 25 deletions(-)
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 4a5ad492435..1c465cb790d 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 class MergeProjectPostProcessor extends
PlanPostProcessor {
Plan newChild = child.accept(this, ctx);
if (newChild instanceof PhysicalProject) {
List<NamedExpression> 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 787be605db1..9ae4c55608b 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 class PlanPostProcessors {
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 class PlanPostProcessors {
}
}
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 3eba798acbf..b5f269b0695 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 @@ package org.apache.doris.nereids.processor.post;
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<? extends Plan> 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<? extends Plan> project = (PhysicalProject<? extends
Plan>) child;
PhysicalFilter<? extends Plan> 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 08b9132b0ca..97786684de0 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 @@ import org.apache.doris.nereids.util.MutableState;
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 b221570edf1..2ca1380d1b0 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 class TopNScanOpt extends PlanPostProcessor {
Plan child = topN.child().accept(this, ctx);
topN = rewriteTopN(topN);
if (child != topN.child()) {
- topN.withChildren(child);
+ topN = ((PhysicalTopN)
topN.withChildren(child)).copyStatsAndGroupIdFrom(topN);
}
return topN;
}
@@ -54,11 +54,11 @@ public class TopNScanOpt extends PlanPostProcessor {
CascadesContext context) {
Plan child = topN.child().accept(this, context);
if (child != topN.child()) {
- topN = topN.withChildren(ImmutableList.of(child));
+ topN =
topN.withChildren(ImmutableList.of(child)).copyStatsAndGroupIdFrom(topN);
}
PhysicalTopN<? extends Plan> rewrittenTopN =
rewriteTopN(topN.getPhysicalTopN());
if (topN.getPhysicalTopN() != rewrittenTopN) {
- topN = topN.withPhysicalTopN(rewrittenTopN);
+ topN =
topN.withPhysicalTopN(rewrittenTopN).copyStatsAndGroupIdFrom(topN);
}
return topN;
}
@@ -103,7 +103,7 @@ public class TopNScanOpt extends PlanPostProcessor {
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 225f0f0dc62..783d3749019 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.AbstractPlan;
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 abstract class AbstractPhysicalPlan extends
AbstractPlan implements Physi
public Plan getExplainPlan(ConnectContext ctx) {
return this;
}
+
+ public <T extends AbstractPhysicalPlan> 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 9d52d12efcd..52a68b9e047 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
@@ -906,7 +906,7 @@ public class SessionVariable implements Serializable,
Writable {
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 a2f9b15ac48..17b8c53fa88 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 class RuntimeFilterTest extends SSBTestBase {
super.runBeforeAll();
connectContext.getSessionVariable().setRuntimeFilterMode("Global");
connectContext.getSessionVariable().setRuntimeFilterType(8);
+ connectContext.getSessionVariable().setEnableRuntimeFilterPrune(false);
+ connectContext.getSessionVariable().expandRuntimeFilterByInnerJoin =
false;
}
@Test
diff --git
a/fe/fe-core/src/test/java/org/apache/doris/planner/QueryPlanTest.java
b/fe/fe-core/src/test/java/org/apache/doris/planner/QueryPlanTest.java
index c6768ab42d5..8bdfb2a1c7c 100644
--- a/fe/fe-core/src/test/java/org/apache/doris/planner/QueryPlanTest.java
+++ b/fe/fe-core/src/test/java/org/apache/doris/planner/QueryPlanTest.java
@@ -63,7 +63,7 @@ public class QueryPlanTest extends TestWithFeService {
protected void runBeforeAll() throws Exception {
// disable bucket shuffle join
Deencapsulation.setField(connectContext.getSessionVariable(),
"enableBucketShuffleJoin", false);
-
+ connectContext.getSessionVariable().setEnableRuntimeFilterPrune(false);
// create database
createDatabase("test");
connectContext.getSessionVariable().setEnableNereidsPlanner(false);
diff --git
a/regression-test/suites/correctness_p0/test_runtimefilter_with_window.groovy
b/regression-test/suites/correctness_p0/test_runtimefilter_with_window.groovy
index 00ec88b20fc..b876ab3de06 100644
---
a/regression-test/suites/correctness_p0/test_runtimefilter_with_window.groovy
+++
b/regression-test/suites/correctness_p0/test_runtimefilter_with_window.groovy
@@ -16,7 +16,8 @@
// under the License.
suite("test_runtimefilter_with_window") {
- sql """ set enable_nereids_planner=false"""
+ sql """ set enable_nereids_planner=true"""
+ sql """ set disable_join_reorder=true"""
sql """ DROP TABLE IF EXISTS `test_runtimefilter_with_window_table1` """
sql """ DROP TABLE IF EXISTS `test_runtimefilter_with_window_table2` """
sql """
@@ -82,9 +83,42 @@ suite("test_runtimefilter_with_window") {
on a.channel_param = b.param; """)
contains "runtime filters"
}
-
- sql """ DROP TABLE IF EXISTS `test_runtimefilter_with_window_table1` """
- sql """ DROP TABLE IF EXISTS `test_runtimefilter_with_window_table2` """
+ sql """ set enable_nereids_planner=false"""
+ sql """ set disable_join_reorder=true"""
+ sql """ set enable_runtime_filter_prune=false"""
+ log.info("======origin planner1=================")
+ explain {
+ sql("""select a.phone
+ ,a.channel_param
+ ,a.createtime
+ ,rn
+ ,if(rn = 1,1,0) as liuzi_status
+ from (
+ select a.phone,a.channel_param,a.createtime
+ ,row_number() over(partition by phone order by
createtime asc) as rn
+ from test_runtimefilter_with_window_table2 a
+ ) a join (
+ select param
+ from test_runtimefilter_with_window_table1
+ ) b
+ on a.channel_param = b.param; """)
+ notContains "runtime filters"
+ }
+log.info("======origin planner2=================")
+ explain {
+ sql("""select a.phone
+ ,a.channel_param
+ ,a.createtime
+ from (
+ select a.phone,a.channel_param,a.createtime
+ from test_runtimefilter_with_window_table2 a
+ ) a join (
+ select param
+ from test_runtimefilter_with_window_table1
+ ) b
+ on a.channel_param = b.param; """)
+ contains "runtime filters"
+ }
}
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 9c16ff65f29..de7d37d1839 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 6218bb5be04..289caf18639 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 124c3be5d6d..e7e12b93788 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 972ab87d7a7..3e9dcab395f 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 c610e21b607..4abe8f4bf3a 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 4f302dd6145..8a6479ba739 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 d83496ff649..0b90f604cd0 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 117705e0828..df87e7eca80 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 dadcc356c13..e15da778854 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 a0ec1492fde..bb61a205c3b 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 05c0fcb69d4..76e44365acd 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 231ba294bca..7bbad11ef5c 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 255be66dbbf..a7b6155cc21 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 bf8c928f0c4..802adab15a7 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 d92daea3a21..ca29142dcc8 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 e5a41b64eba..dd11e7e2671 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 39d1987ecd9..0984f4df110 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 4047b407b3f..5d34c892b05 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 ecede80079b..75c228b8a24 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 9f3cbaebb46..9b4ba4a8356 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 ffdc78da1ed..7fc17b07f06 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 2ef32fdac41..705561e3943 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 1f0e968c517..42a00e2fb0d 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 216be9f09ee..1a179bf5434 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 65724117c8f..f7dcbe09191 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 b3da12ed061..26a64a16666 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 576df6a8773..63d9c4ea83f 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 c9c44210696..b979714ccd6 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 978e7bf6db2..01eb27f7954 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 d4110b005ce..620b0970e02 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 be9a4d57c2a..d25242f23a5 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 53a78e727f7..8869995ddd0 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 35d44352658..a609d87ad1e 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 ca12fdd1928..bd696286027 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 cd9cee0cef5..02998649b45 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 96a557b9f6b..5414b93cb9d 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 e931f532fde..77637a7b8b2 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 3509fe46e14..1eb73d69a1e 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 f1f43102a14..f07a996f768 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 7e6ddb64b9c..07c00fd6816 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 44343e3fee4..042868ff226 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 983a312b0ac..9fb9712a21d 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 69a99bdcc66..b6de6acf252 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 71f514a0f55..a49a2af3183 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 7f89351feac..9ea2f27d4e2 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 9d7942f8f78..3ac376e4cbc 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 99ae46e0718..2e107e4893f 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 512a10bc9d5..54682f63c70 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 e56a71c0664..75940a51b38 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 47142102dca..5e7a32194ad 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 88431716efc..f75ee0d02ae 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 247038317b1..3d148e731e6 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 ef8d218104f..31750145181 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 b9d3fbe6ded..384c2d4a13b 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 4c937338e72..93f40317d04 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 af6fea1f90c..abecbdcd0ad 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 d0ca9e11f58..7a01a6706df 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 96d5edec07c..c91fbb2c021 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 f567f8c0775..722fc56a5ec 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 06ee4e2ec78..9e28fbf7b3f 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 f8b4f3d893d..9b093dafa28 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 51940e2b51f..683de734513 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 b7a5e2fb273..d475614491f 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 fcd2b464dfe..bfa158d5c07 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 063f8f37acb..aea9206edac 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 6ee1d11899d..9d5b9d48b0a 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 f2cfedf9d68..b4bea33b9a0 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 c5b09f74070..fad69d7dda9 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 41245523d82..a059ef6ae93 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 ac19b330fa9..4c6ba1d05fd 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 df86fa05c0c..92e1660cce5 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 cee6c57122f..456b4a8b79e 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 75ed33223b0..630152cfd65 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 23ea01d3a54..41b8d8d8837 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 ab820977029..fcc064857d3 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 ebe3f3f7b23..99b6a38b456 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 4eabc54415d..6c4549151ca 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 6d5fe6967e7..e45a6a11ba8 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 e049568c92c..3765f283426 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 739fbb942cc..a41bdd43564 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 77d4fb0b875..1309fede04c 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 f996c6bc61a..7144fe13c98 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 6a9424e4577..51be93e9394 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 1454f752e2c..23c0d7a2f1f 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 b716a2a89d2..9f5999c833f 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 4b14c597f9b..b2bc785d82d 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 79b6c1f7387..667c04af024 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 e3a859ccc8c..b33e94c6326 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 56ff92bfbcb..10959909109 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 c43bab96ffa..a57d6f5a848 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 d7f99b5ff66..eae00c6c986 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 8145425acdf..a0a1ec8fe7b 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 29ea53baca8..ad8dc98d631 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 0b53b5f408a..5cfc60f9ff5 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 73bc55ffbcc..4eb9be15261 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 689c0467102..97e10cd2fc2 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 204fb9edfc0..5253b27a899 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 8c5c1c1bf9a..65959ecab9e 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 9179f7ab4f9..18dea274384 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 4f627fb7215..9999be39541 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 21010ec4ee0..feb99537035 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 b798e3c1193..81c2b9ca1f1 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 60b208e7fdf..e92e31dfef0 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 98979272b33..e272dbb2a60 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 2561f76cd76..66866e1a003 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 3ea24d8f144..1820786da0b 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 d7d0743b45d..58ed949bd1f 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 b8324f83116..7f795350b8f 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 614836609f7..c2c9364d33d 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 ec15e306de6..61039d3d548 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 31ee643b8fc..2ba80c7caff 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 594168a3fbc..d49e5297908 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 6f04945edc0..2a014e67d12 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 07f34f94392..d88543c1ff6 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 933f66c1df5..34da1d1deab 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 e67319429d6..54016fe020a 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 fe08dd277cc..924d8b8c9b4 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 32993b7b73d..fcf125ce4b0 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 045b6fb62d9..dabcb2b481b 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 c53f51918f8..9aa90460186 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 283f75263ef..02a6d4f8571 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 76d0eec9938..f42a8a6e150 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 7044e5fab46..856eda2aed5 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
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
