This is an automated email from the ASF dual-hosted git repository. jackietien pushed a commit to branch new_object_type in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 62cca0760eca23cd547ee170d8429231a435bf48 Author: JackieTien97 <[email protected]> AuthorDate: Sun Jul 13 10:46:37 2025 +0800 Add compress for geo_penetrate --- .../dag/column/unary/scalar/ReadObjectColumnTransformer.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) 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 84a094e39fe..17acfdd0dbd 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 @@ -20,6 +20,7 @@ package org.apache.iotdb.db.queryengine.transformation.dag.column.unary.scalar; import org.apache.iotdb.commons.exception.IoTDBRuntimeException; +import org.apache.iotdb.db.exception.sql.SemanticException; import org.apache.iotdb.db.queryengine.execution.fragment.FragmentInstanceContext; import org.apache.iotdb.db.queryengine.transformation.dag.column.ColumnTransformer; import org.apache.iotdb.db.queryengine.transformation.dag.column.unary.UnaryColumnTransformer; @@ -109,11 +110,11 @@ public class ReadObjectColumnTransformer extends UnaryColumnTransformer { File file = ObjectTypeUtils.getObjectPathFromBinary(binary); long fileSize = file.length(); if (offset >= fileSize) { - throw new UnsupportedOperationException("offset is greater than object size"); + throw new SemanticException("offset is greater than object size"); } long actualReadSize = Math.min(length < 0 ? fileSize : length, fileSize - offset); if (actualReadSize > Integer.MAX_VALUE) { - throw new UnsupportedOperationException("Read object size is too large (size > 2G)"); + throw new SemanticException("Read object size is too large (size > 2G)"); } fragmentInstanceContext.ifPresent( context -> context.getMemoryReservationContext().reserveMemoryCumulatively(actualReadSize));
