This is an automated email from the ASF dual-hosted git repository.
justinchen pushed a commit to branch ger-fix
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/ger-fix by this push:
new 015e9912f3f root-fix
015e9912f3f is described below
commit 015e9912f3fd91fe7fcf9c83c44e38c026cd165f
Author: Caideyipi <[email protected]>
AuthorDate: Thu Jan 22 16:20:32 2026 +0800
root-fix
---
.../org/apache/iotdb/db/storageengine/load/LoadTsFileManager.java | 6 ++----
1 file changed, 2 insertions(+), 4 deletions(-)
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/LoadTsFileManager.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/LoadTsFileManager.java
index 082106bb5fd..83372a5a6c0 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/LoadTsFileManager.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/LoadTsFileManager.java
@@ -32,6 +32,7 @@ import org.apache.iotdb.commons.service.metric.MetricService;
import org.apache.iotdb.commons.service.metric.enums.Metric;
import org.apache.iotdb.commons.service.metric.enums.Tag;
import org.apache.iotdb.commons.utils.FileUtils;
+import org.apache.iotdb.commons.utils.PathUtils;
import org.apache.iotdb.commons.utils.RetryUtils;
import org.apache.iotdb.db.conf.IoTDBConfig;
import org.apache.iotdb.db.conf.IoTDBDescriptor;
@@ -92,9 +93,6 @@ import java.util.concurrent.atomic.AtomicReference;
import java.util.stream.Collectors;
import java.util.stream.Stream;
-import static org.apache.iotdb.db.utils.constant.SqlConstant.ROOT;
-import static
org.apache.iotdb.db.utils.constant.SqlConstant.TREE_MODEL_DATABASE_PREFIX;
-
/**
* {@link LoadTsFileManager} is used for dealing with {@link
LoadTsFilePieceNode} and {@link
* LoadCommand}. This class turn the content of a piece of loading TsFile into
a new TsFile. When
@@ -489,7 +487,7 @@ public class LoadTsFileManager {
final String tableName =
chunkData.getDevice() != null ? chunkData.getDevice().getTableName()
: null;
if (tableName != null
- && !(tableName.startsWith(TREE_MODEL_DATABASE_PREFIX) ||
tableName.equals(ROOT))) {
+ &&
PathUtils.isTableModelDatabase(partitionInfo.getDataRegion().getDatabaseName()))
{
// If the table does not exist, it means that the table is all deleted
by mods
final TsTable table =
DataNodeTableCache.getInstance()
