This is an automated email from the ASF dual-hosted git repository.
morningman pushed a commit to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-3.0 by this push:
new 9add76b4d24 branch-3.0: [bugfix](hive)Fix split assignment leak.
releated to issue (#40683). #44845 (#45143)
9add76b4d24 is described below
commit 9add76b4d24911ea8c792ba026cd950b9b637cbe
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Fri Dec 6 22:07:54 2024 -0800
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]>
---
.../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 9845c0070fc..29fdb2b09ac 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
@@ -126,7 +126,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 d4fce906693..e3f2f1d732a 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
@@ -27,6 +27,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;
@@ -95,6 +96,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]
