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


The following commit(s) were added to refs/heads/object_type by this push:
     new cbc45de159b make offset of read_object take effective
cbc45de159b is described below

commit cbc45de159b0d5bb561ff797be93e00f430cb54e
Author: JackieTien97 <jackietie...@gmail.com>
AuthorDate: Mon Aug 11 18:51:06 2025 +0800

    make offset of read_object take effective
---
 .../dag/column/unary/scalar/ReadObjectColumnTransformer.java            | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/ReadObjectColumnTransformer.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/ReadObjectColumnTransformer.java
index 17acfdd0dbd..02134d720d6 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/ReadObjectColumnTransformer.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/ReadObjectColumnTransformer.java
@@ -121,7 +121,7 @@ public class ReadObjectColumnTransformer extends 
UnaryColumnTransformer {
     byte[] bytes = new byte[(int) actualReadSize];
     ByteBuffer buffer = ByteBuffer.wrap(bytes);
     try (FileChannel fileChannel = FileChannel.open(file.toPath(), 
StandardOpenOption.READ)) {
-      fileChannel.read(buffer);
+      fileChannel.read(buffer, offset);
     } catch (IOException e) {
       throw new IoTDBRuntimeException(e, 
TSStatusCode.INTERNAL_SERVER_ERROR.getStatusCode());
     }

Reply via email to