This is an automated email from the ASF dual-hosted git repository.
morningman pushed a commit to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.1 by this push:
new 02840a98ffa branch-2.1: [bugfix](hive)Fix split assignment leak.
releated to issue (#40683). #44845 (#45144)
02840a98ffa is described below
commit 02840a98ffab9907ea457d63461d988ce045ea15
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Fri Dec 6 22:10:50 2024 -0800
branch-2.1: [bugfix](hive)Fix split assignment leak. releated to issue
(#40683). #44845 (#45144)
Cherry-picked from #44845
Co-authored-by: sparrow <[email protected]>
---
.../src/main/java/org/apache/doris/datasource/FileScanNode.java | 1 -
.../org/apache/doris/nereids/trees/plans/commands/ExplainCommand.java | 4 ++++
2 files changed, 4 insertions(+), 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
index 457a580e520..1b2b15c0ec5 100644
--- 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
@@ -124,7 +124,6 @@ public abstract class FileScanNode extends ExternalScanNode
{
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
index 4093c7f0e1b..a839094ec17 100644
---
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
@@ -26,6 +26,7 @@ import org.apache.doris.nereids.trees.plans.Explainable;
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;
@@ -93,6 +94,9 @@ public class ExplainCommand extends Command implements
NoForward {
} else {
executor.handleExplainStmt(planner.getExplainString(explainOptions), true);
}
+ for (ScanNode scanNode : planner.getScanNodes()) {
+ scanNode.stop();
+ }
}
@Override
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
