This is an automated email from the ASF dual-hosted git repository. lancelly pushed a commit to branch identity in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit bc78da3c2d54ce61398cb22df692f1e2a560c723 Author: lancelly <[email protected]> AuthorDate: Thu Jun 6 19:29:32 2024 +0800 fix --- .../iotdb/db/queryengine/plan/planner/OperatorTreeGenerator.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/OperatorTreeGenerator.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/OperatorTreeGenerator.java index 99dba242ef8..93fef134f5f 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/OperatorTreeGenerator.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/OperatorTreeGenerator.java @@ -2538,10 +2538,10 @@ public class OperatorTreeGenerator extends PlanVisitor<Operator, LocalExecutionP localInstanceId.toThrift(), node.getPlanNodeId().getId(), context.getInstanceContext()); - sinkHandle.setMaxBytesCanReserve(context.getMaxBytesOneHandleCanReserve()); + List<Operator> children = dealWithConsumeChildrenOneByOneNode(node, context); context.getDriverContext().setSink(sinkHandle); - List<Operator> children = dealWithConsumeChildrenOneByOneNode(node, context); + sinkHandle.setMaxBytesCanReserve(context.getMaxBytesOneHandleCanReserve()); return new IdentitySinkOperator(operatorContext, children, downStreamChannelIndex, sinkHandle); }
