This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.1 by this push:
new 6974a8fc4ab branch-2.1: [opt](nereids)do not apply CSE(Common Sub
Expression) upon multiDataSink #33746 (#49797)
6974a8fc4ab is described below
commit 6974a8fc4abcc8403a58c0cf9a02282a19318a9d
Author: minghong <zhoumingh...@selectdb.com>
AuthorDate: Fri Apr 4 20:49:07 2025 +0800
branch-2.1: [opt](nereids)do not apply CSE(Common Sub Expression) upon
multiDataSink #33746 (#49797)
---
.../apache/doris/nereids/glue/translator/PhysicalPlanTranslator.java | 2 +-
fe/fe-core/src/main/java/org/apache/doris/planner/RuntimeFilter.java | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/nereids/glue/translator/PhysicalPlanTranslator.java
b/fe/fe-core/src/main/java/org/apache/doris/nereids/glue/translator/PhysicalPlanTranslator.java
index 5d70a401ce7..5b326d2048a 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/nereids/glue/translator/PhysicalPlanTranslator.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/nereids/glue/translator/PhysicalPlanTranslator.java
@@ -1883,7 +1883,7 @@ public class PhysicalPlanTranslator extends
DefaultPlanVisitor<PlanFragment, Pla
List<Expr> projectionExprs = null;
List<Expr> allProjectionExprs = Lists.newArrayList();
List<Slot> slots = null;
- if (project.hasMultiLayerProjection()) {
+ if (project.hasMultiLayerProjection() && !(inputFragment instanceof
MultiCastPlanFragment)) {
int layerCount = project.getMultiLayerProjects().size();
for (int i = 0; i < layerCount; i++) {
List<NamedExpression> layer =
project.getMultiLayerProjects().get(i);
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/planner/RuntimeFilter.java
b/fe/fe-core/src/main/java/org/apache/doris/planner/RuntimeFilter.java
index 7decc5c2baa..ad40367318a 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/planner/RuntimeFilter.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/planner/RuntimeFilter.java
@@ -674,7 +674,7 @@ public final class RuntimeFilter {
* Assigns this runtime filter to the corresponding plan nodes.
*/
public void assignToPlanNodes() {
- Preconditions.checkState(hasTargets());
+ Preconditions.checkState(hasTargets(), this.toString() + " has no
target");
builderNode.addRuntimeFilter(this);
builderNode.fragment.setBuilderRuntimeFilterIds(getFilterId());
for (RuntimeFilterTarget target : targets) {
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
