Throw exception while readObject column is not OBJECT type

JackieTien97 · JackieTien97 · commit fb38bd938e36 · 2025-12-18T11:30:42.000+08:00
diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/function/partition/Slice.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/function/partition/Slice.java
@@ -221,6 +221,9 @@ public Optional<File> getObjectFile(int columnIndex) {
 
     @Override
     public Binary readObject(int columnIndex, long offset, int length) {
+      if (getDataType(columnIndex) != Type.OBJECT) {
+        throw new UnsupportedOperationException("current column is not object column");
+      }
       Binary binary = getBinarySafely(columnIndex);
       return new Binary(ObjectTypeUtils.readObjectContent(binary, offset, length, true).array());
     }
diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/RecordIterator.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/RecordIterator.java
@@ -166,6 +166,9 @@ public Optional<File> getObjectFile(int columnIndex) {
 
     @Override
     public Binary readObject(int columnIndex, long offset, int length) {
+      if (getDataType(columnIndex) != Type.OBJECT) {
+        throw new UnsupportedOperationException("current column is not object column");
+      }
       Binary binary = getBinarySafely(columnIndex);
       return new Binary(ObjectTypeUtils.readObjectContent(binary, offset, length, true).array());
     }

Original file line number	Diff line number	Diff line change
`@@ -221,6 +221,9 @@ public Optional<File> getObjectFile(int columnIndex) {`
`221`	`221`
`222`	`222`	`@Override`
`223`	`223`	`public Binary readObject(int columnIndex, long offset, int length) {`
	`224`	`+ if (getDataType(columnIndex) != Type.OBJECT) {`
	`225`	`+ throw new UnsupportedOperationException("current column is not object column");`
	`226`	`+ }`
`224`	`227`	`Binary binary = getBinarySafely(columnIndex);`
`225`	`228`	`return new Binary(ObjectTypeUtils.readObjectContent(binary, offset, length, true).array());`
`226`	`229`	`}`
Original file line number	Diff line number	Diff line change
`@@ -166,6 +166,9 @@ public Optional<File> getObjectFile(int columnIndex) {`
`166`	`166`
`167`	`167`	`@Override`
`168`	`168`	`public Binary readObject(int columnIndex, long offset, int length) {`
	`169`	`+ if (getDataType(columnIndex) != Type.OBJECT) {`
	`170`	`+ throw new UnsupportedOperationException("current column is not object column");`
	`171`	`+ }`
`169`	`172`	`Binary binary = getBinarySafely(columnIndex);`
`170`	`173`	`return new Binary(ObjectTypeUtils.readObjectContent(binary, offset, length, true).array());`
`171`	`174`	`}`