(iotdb) branch master updated: Fix wrong calculation for maxBytesCanReserve for IdentitySinkOperator

[jackietien]

This is an automated email from the ASF dual-hosted git repository.

jackietien pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/master by this push:
     new 2d04d22d5fe Fix wrong calculation for maxBytesCanReserve for 
IdentitySinkOperator
2d04d22d5fe is described below

commit 2d04d22d5fe72ba76dee37c621cf54456ca0b477
Author: Liao Lanyu <1435078...@qq.com>
AuthorDate: Fri Jun 7 09:45:19 2024 +0800

    Fix wrong calculation for maxBytesCanReserve for IdentitySinkOperator
---
 .../apache/iotdb/db/queryengine/plan/planner/OperatorTreeGenerator.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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..26a7ab2aa27 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());
+    List<Operator> children = dealWithConsumeChildrenOneByOneNode(node, 
context);
     sinkHandle.setMaxBytesCanReserve(context.getMaxBytesOneHandleCanReserve());
     context.getDriverContext().setSink(sinkHandle);
 
-    List<Operator> children = dealWithConsumeChildrenOneByOneNode(node, 
context);
     return new IdentitySinkOperator(operatorContext, children, 
downStreamChannelIndex, sinkHandle);
   }