This is an automated email from the ASF dual-hosted git repository. jackietien pushed a commit to branch object_type in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit e352985a7ba1c5ebc173e20f196afd8c8e386b72 Author: JackieTien97 <[email protected]> AuthorDate: Fri Jul 11 18:07:39 2025 +0800 Correct Memory Allocation for SinkHandle in Table model --- .../iotdb/db/queryengine/plan/planner/TableOperatorGenerator.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/TableOperatorGenerator.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/TableOperatorGenerator.java index 811af011a90..17f53216d40 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/TableOperatorGenerator.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/TableOperatorGenerator.java @@ -376,13 +376,13 @@ public class TableOperatorGenerator extends PlanVisitor<Operator, LocalExecution localInstanceId.toThrift(), node.getPlanNodeId().getId(), context.getInstanceContext()); - sinkHandle.setMaxBytesCanReserve(context.getMaxBytesOneHandleCanReserve()); - context.getDriverContext().setSink(sinkHandle); if (node.getChildren().size() == 1) { Operator child = node.getChildren().get(0).accept(this, context); List<Operator> children = new ArrayList<>(1); children.add(child); + sinkHandle.setMaxBytesCanReserve(context.getMaxBytesOneHandleCanReserve()); + context.getDriverContext().setSink(sinkHandle); return new IdentitySinkOperator( operatorContext, children, downStreamChannelIndex, sinkHandle); } else {
