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 <[email protected]>
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());
}