This is an automated email from the ASF dual-hosted git repository.
jiangtian 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 cea26a1450e [To object_type] Fix wrong object value inserted (#15928)
cea26a1450e is described below
commit cea26a1450e65a5eb27007ed8dd82dc976aea81d
Author: Haonan <[email protected]>
AuthorDate: Mon Jul 14 10:52:11 2025 +0800
[To object_type] Fix wrong object value inserted (#15928)
---
.../plan/planner/plan/node/write/RelationalInsertTabletNode.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/write/RelationalInsertTabletNode.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/write/RelationalInsertTabletNode.java
index 609b940bfca..8975e7b9b02 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/write/RelationalInsertTabletNode.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/write/RelationalInsertTabletNode.java
@@ -442,11 +442,11 @@ public class RelationalInsertTabletNode extends
InsertTabletNode {
System.arraycopy(times, start, subNode.times, destLoc, length);
for (int i = 0; i < subNode.columns.length; i++) {
if (dataTypes[i] != null) {
+ if (dataTypes[i] == TSDataType.OBJECT) {
+ handleObjectValue(i, start, end, entry, result);
+ }
System.arraycopy(columns[i], start, subNode.columns[i], destLoc,
length);
}
- if (dataTypes[i] == TSDataType.OBJECT) {
- handleObjectValue(i, start, end, entry, result);
- }
if (subNode.bitMaps != null && this.bitMaps[i] != null) {
BitMap.copyOfRange(this.bitMaps[i], start, subNode.bitMaps[i],
destLoc, length);
}