fix

apache · Jan 11, 2024 · 744b241 · 744b241
1 parent 3aa1b94
commit 744b241
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...e-core/src/main/java/org/apache/doris/nereids/processor/post/AddOffsetIntoDistribute.java b/...e-core/src/main/java/org/apache/doris/nereids/processor/post/AddOffsetIntoDistribute.java
@@ -33,7 +33,7 @@ public class AddOffsetIntoDistribute extends PlanPostProcessor {
     @Override
     public Plan visitPhysicalLimit(PhysicalLimit<? extends Plan> limit, CascadesContext context) {
         if (limit.getPhase().isLocal() || limit.getOffset() == 0) {
-            return null;
+            return limit;
         }
 
         return new PhysicalDistribute<>(DistributionSpecGather.INSTANCE,
@@ -43,7 +43,7 @@ public Plan visitPhysicalLimit(PhysicalLimit<? extends Plan> limit, CascadesCont
     @Override
     public Plan visitPhysicalTopN(PhysicalTopN<? extends Plan> topN, CascadesContext context) {
         if (topN.getSortPhase().isLocal() || topN.getOffset() == 0) {
-            return null;
+            return topN;
         }
 
         return new PhysicalDistribute<>(DistributionSpecGather.INSTANCE,