branch-3.0: [bugfix](hive)Fix split assignment leak. releated to issue (

#40683). #44845 (#45143) Cherry-picked from #44845 Co-authored-by: sparrow <[email protected]>
apache · Dec 7, 2024 · 9add76b · 9add76b
1 parent 7df5c10
commit 9add76b
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 1 deletion.
diff --git a/fe/fe-core/src/main/java/org/apache/doris/datasource/FileScanNode.java b/fe/fe-core/src/main/java/org/apache/doris/datasource/FileScanNode.java
@@ -126,7 +126,6 @@ public String getNodeExplainString(String prefix, TExplainLevel detailLevel) {
         output.append(prefix);
         if (isBatchMode()) {
             output.append("(approximate)");
-            splitAssignment.stop();
         }
         output.append("inputSplitNum=").append(selectedSplitNum).append(", totalFileSize=")
             .append(totalFileSize).append(", scanRanges=").append(scanRangeLocations.size()).append("\n");

diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/ExplainCommand.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/ExplainCommand.java
@@ -27,6 +27,7 @@
 import org.apache.doris.nereids.trees.plans.PlanType;
 import org.apache.doris.nereids.trees.plans.logical.LogicalPlan;
 import org.apache.doris.nereids.trees.plans.visitor.PlanVisitor;
+import org.apache.doris.planner.ScanNode;
 import org.apache.doris.qe.ConnectContext;
 import org.apache.doris.qe.StmtExecutor;
 
@@ -95,6 +96,9 @@ public void run(ConnectContext ctx, StmtExecutor executor) throws Exception {
         } else {
             executor.handleExplainStmt(planner.getExplainString(explainOptions), true);
         }
+        for (ScanNode scanNode : planner.getScanNodes()) {
+            scanNode.stop();
+        }
     }
 
     @Override