fix

apache · Aug 14, 2024 · d56caa4 · d56caa4
1 parent e8da090
commit d56caa4
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/...e-core/src/main/java/org/apache/doris/nereids/glue/translator/PhysicalPlanTranslator.java b/...e-core/src/main/java/org/apache/doris/nereids/glue/translator/PhysicalPlanTranslator.java
@@ -1830,9 +1830,9 @@ public PlanFragment visitPhysicalLimit(PhysicalLimit<? extends Plan> physicalLim
         PlanFragment inputFragment = physicalLimit.child(0).accept(this, context);
         PlanNode child = inputFragment.getPlanRoot();
 
-        if (!(inputFragment.getPlanRoot() instanceof ExchangeNode)) {
-            inputFragment.getPlanRoot().setLimit(physicalLimit.getLimit());
-            inputFragment.getPlanRoot().setOffset(physicalLimit.getOffset());
+        if (!(child instanceof ExchangeNode)) {
+            child.setLimit(physicalLimit.getLimit());
+            child.setOffset(physicalLimit.getOffset());
             return inputFragment;
         } else {
             child.setLimit(MergeLimits.mergeLimit(physicalLimit.getLimit(), physicalLimit.getOffset(),