database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

branch-2.1: [bugfix](hive)Fix split assignment leak. releated to issue (#40683). #44845 (#45144)

Browse Source 
Cherry-picked from #44845

Co-authored-by: sparrow <38098988+biohazard4321@users.noreply.github.com>
This commit is contained in:
github-actions[bot]
2024-12-06 22:10:50 -08:00
committed by GitHub
parent 8f0276809a
commit 02840a98ff
2 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
fe/fe-core/src/main/java/org/apache/doris/datasource/FileScanNode.java
View File

@ -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");

4
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/ExplainCommand.java
View File

@ -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