You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ca...@apache.org on 2024/07/25 04:15:10 UTC
(iotdb) 01/01: fix serialize method of Limit/OffsetNode
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 bed2f258dd119fa47a97de01b9fb0ff758fb6e23
Author: Beyyes <cg...@foxmail.com>
AuthorDate: Thu Jul 25 12:14:55 2024 +0800
fix serialize method of Limit/OffsetNode
---
.../iotdb/db/queryengine/plan/relational/planner/node/LimitNode.java | 2 +-
.../iotdb/db/queryengine/plan/relational/planner/node/OffsetNode.java | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/node/LimitNode.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/node/LimitNode.java
index 8e7b0292b0a..f99a250f69d 100644
--- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/node/LimitNode.java
+++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/node/LimitNode.java
@@ -80,7 +80,7 @@ public class LimitNode extends SingleChildProcessNode {
}
public static LimitNode deserialize(ByteBuffer byteBuffer) {
- long count = ReadWriteIOUtils.read(byteBuffer);
+ long count = ReadWriteIOUtils.readLong(byteBuffer);
PlanNodeId planNodeId = PlanNodeId.deserialize(byteBuffer);
return new LimitNode(planNodeId, null, count, null);
}
diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/node/OffsetNode.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/node/OffsetNode.java
index fc363190d2b..ba2f84418fe 100644
--- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/node/OffsetNode.java
+++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/node/OffsetNode.java
@@ -66,7 +66,7 @@ public class OffsetNode extends SingleChildProcessNode {
}
public static OffsetNode deserialize(ByteBuffer byteBuffer) {
- long count = ReadWriteIOUtils.read(byteBuffer);
+ long count = ReadWriteIOUtils.readLong(byteBuffer);
PlanNodeId planNodeId = PlanNodeId.deserialize(byteBuffer);
return new OffsetNode(planNodeId, null, count);
}