diff --git a/fe/fe-core/src/main/java/org/apache/doris/planner/JoinNodeBase.java b/fe/fe-core/src/main/java/org/apache/doris/planner/JoinNodeBase.java index a460ea0f75..fe035d3105 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/planner/JoinNodeBase.java +++ b/fe/fe-core/src/main/java/org/apache/doris/planner/JoinNodeBase.java @@ -585,6 +585,7 @@ public abstract class JoinNodeBase extends PlanNode { rhsExpr = rhsExpr.substitute(tmpSmap); vSrcToOutputSMap.getLhs().add(rhsExpr); SlotRef slotRef = new SlotRef(slotDesc); + slotRef.materializeSrcExpr(); vSrcToOutputSMap.getRhs().add(slotRef); newRhs.add(slotRef); bSmapChanged = true;