diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/copier/LogicalPlanDeepCopier.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/copier/LogicalPlanDeepCopier.java index 90010911ff915a..e5b341938fd393 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/copier/LogicalPlanDeepCopier.java +++ b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/copier/LogicalPlanDeepCopier.java @@ -214,7 +214,7 @@ public Plan visitLogicalTopN(LogicalTopN topN, DeepCopierContext .map(o -> new OrderKey(ExpressionDeepCopier.INSTANCE.deepCopy(o.getExpr(), context), o.isAsc(), o.isNullFirst())) .collect(ImmutableList.toImmutableList()); - return new LogicalTopN<>(orderKeys, topN.getLimit(), topN.getOffset(), child, false); + return new LogicalTopN<>(orderKeys, topN.getLimit(), topN.getOffset(), child, topN.isPushed()); } @Override @@ -241,7 +241,7 @@ public Plan visitLogicalPartitionTopN(LogicalPartitionTopN parti .map(o -> (OrderExpression) ExpressionDeepCopier.INSTANCE.deepCopy(o, context)) .collect(ImmutableList.toImmutableList()); return new LogicalPartitionTopN<>(partitionTopN.getFunction(), partitionKeys, orderKeys, - partitionTopN.hasGlobalLimit(), partitionTopN.getPartitionLimit(), child, false); + partitionTopN.hasGlobalLimit(), partitionTopN.getPartitionLimit(), child, partitionTopN.isPushed()); } @Override