diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/processor/post/TwoPhaseReadOpt.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/processor/post/TwoPhaseReadOpt.java index 543f908456..18b7dbdf7f 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/nereids/processor/post/TwoPhaseReadOpt.java +++ b/fe/fe-core/src/main/java/org/apache/doris/nereids/processor/post/TwoPhaseReadOpt.java @@ -92,6 +92,7 @@ public class TwoPhaseReadOpt extends PlanPostProcessor { PhysicalOlapScan olapScan; PhysicalProject project = null; PhysicalFilter filter = null; + child = localTopN.child(); while (child instanceof Project || child instanceof Filter) { if (child instanceof Filter) { filter = (PhysicalFilter) child;