This is an automated email from the ASF dual-hosted git repository. caogaofei pushed a commit to branch beyyes/fix_limit_offset_serialie in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 4d5d83450deca1c3f4615a06381e1d35fc43fe25 Author: Beyyes <[email protected]> AuthorDate: Thu Jul 25 14:18:53 2024 +0800 fix serialize method of CollectNode --- .../iotdb/db/queryengine/plan/relational/planner/node/CollectNode.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/node/CollectNode.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/node/CollectNode.java index 668ee384909..5fa3d34ac6a 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/node/CollectNode.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/node/CollectNode.java @@ -102,12 +102,12 @@ public class CollectNode extends MultiChildProcessNode { } public static CollectNode deserialize(ByteBuffer byteBuffer) { - PlanNodeId planNodeId = PlanNodeId.deserialize(byteBuffer); int size = ReadWriteIOUtils.readInt(byteBuffer); List<Symbol> outputs = new ArrayList<>(size); while (size-- > 0) { outputs.add(Symbol.deserialize(byteBuffer)); } + PlanNodeId planNodeId = PlanNodeId.deserialize(byteBuffer); CollectNode collectNode = new CollectNode(planNodeId); collectNode.setOutputSymbols(outputs); return collectNode;
