(iotdb) branch master updated: Load: Fixed the index update logic of tree-model (#15474)

[rong]

This is an automated email from the ASF dual-hosted git repository.

rong pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/master by this push:
     new 5d5c8b33cc8 Load: Fixed the index update logic of tree-model (#15474)
5d5c8b33cc8 is described below

commit 5d5c8b33cc82a2869c2790185d60d12d9e181f68
Author: Caideyipi <87789683+caidey...@users.noreply.github.com>
AuthorDate: Thu May 8 12:45:52 2025 +0800

    Load: Fixed the index update logic of tree-model (#15474)
---
 .../iotdb/db/queryengine/plan/analyze/load/LoadTsFileAnalyzer.java   | 2 +-
 .../db/queryengine/plan/analyze/load/LoadTsFileTreeSchemaCache.java  | 4 ++++
 .../plan/analyze/load/TreeSchemaAutoCreatorAndVerifier.java          | 5 +++++
 3 files changed, 10 insertions(+), 1 deletion(-)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/load/LoadTsFileAnalyzer.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/load/LoadTsFileAnalyzer.java
index fb8afc5ca58..62483a3a3c5 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/load/LoadTsFileAnalyzer.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/load/LoadTsFileAnalyzer.java
@@ -516,7 +516,7 @@ public class LoadTsFileAnalyzer implements AutoCloseable {
 
       if (!tsFileResource.resourceFileExists()) {
         TsFileResourceUtils.updateTsFileResource(device2TimeseriesMetadata, 
tsFileResource);
-        
getOrCreateTableSchemaCache().setCurrentTimeIndex(tsFileResource.getTimeIndex());
+        
getOrCreateTreeSchemaVerifier().setCurrentTimeIndex(tsFileResource.getTimeIndex());
       }
 
       if (isAutoCreateSchemaOrVerifySchemaEnabled) {
diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/load/LoadTsFileTreeSchemaCache.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/load/LoadTsFileTreeSchemaCache.java
index 6bd72972d4b..59068bde706 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/load/LoadTsFileTreeSchemaCache.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/load/LoadTsFileTreeSchemaCache.java
@@ -188,6 +188,10 @@ public class LoadTsFileTreeSchemaCache {
     }
   }
 
+  public void setCurrentTimeIndex(final ITimeIndex timeIndex) {
+    currentTimeIndex = timeIndex;
+  }
+
   public boolean isDeviceDeletedByMods(IDeviceID device) throws 
IllegalPathException {
     return ModificationUtils.isDeviceDeletedByMods(currentModifications, 
currentTimeIndex, device);
   }
diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/load/TreeSchemaAutoCreatorAndVerifier.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/load/TreeSchemaAutoCreatorAndVerifier.java
index 826b7c592d8..dc62a647cad 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/load/TreeSchemaAutoCreatorAndVerifier.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/load/TreeSchemaAutoCreatorAndVerifier.java
@@ -52,6 +52,7 @@ import 
org.apache.iotdb.db.queryengine.plan.statement.Statement;
 import 
org.apache.iotdb.db.queryengine.plan.statement.metadata.DatabaseSchemaStatement;
 import 
org.apache.iotdb.db.queryengine.plan.statement.metadata.ShowDatabaseStatement;
 import org.apache.iotdb.db.storageengine.dataregion.tsfile.TsFileResource;
+import 
org.apache.iotdb.db.storageengine.dataregion.tsfile.timeindex.ITimeIndex;
 import org.apache.iotdb.db.utils.constant.SqlConstant;
 import org.apache.iotdb.rpc.TSStatusCode;
 
@@ -102,6 +103,10 @@ public class TreeSchemaAutoCreatorAndVerifier {
     schemaCache.setCurrentModificationsAndTimeIndex(resource, reader);
   }
 
+  public void setCurrentTimeIndex(final ITimeIndex timeIndex) {
+    schemaCache.setCurrentTimeIndex(timeIndex);
+  }
+
   public void autoCreateAndVerify(
       TsFileSequenceReader reader,
       Map<IDeviceID, List<TimeseriesMetadata>> device2TimeseriesMetadataList)