Load: Fixed the bug that active load may fail for table model (#17124)

Author: Caideyipi

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/load/LoadTsFileAnalyzer.java

@@ -574,7 +574,11 @@ private void doAnalyzeSingleTableFile(
 
     getOrCreateTableSchemaCache().flush();
     if (getOrCreateTableSchemaCache().isNeedDecode4DifferentTimeColumn()) {
-      loadTsFileTableStatement.enableNeedDecode4TimeColumn();
+      if (isTableModelStatement) {
+        loadTsFileTableStatement.enableNeedDecode4TimeColumn();
+      } else {
+        loadTsFileTreeStatement.enableNeedDecode4TimeColumn();
+      }
     }
     getOrCreateTableSchemaCache().clearTagColumnMapper();
 

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/LogicalPlanVisitor.java

@@ -549,7 +549,7 @@ public PlanNode visitLoadFile(
         loadTsFileStatement.getResources(),
         isTableModel,
         loadTsFileStatement.getDatabase(),
-        false);
+        loadTsFileStatement.isNeedDecode4TimeColumn());
   }
 
   @Override

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/load/LoadTsFileNode.java

@@ -128,7 +128,7 @@ private List<WritePlanNode> splitByPartitionForTreeModel(Analysis analysis) {
               database,
               statement.isDeleteAfterLoad(),
               statement.getWritePointCount(i),
-              false));
+              needDecode4TimeColumn));
     }
     return res;
   }

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/crud/LoadTsFileStatement.java

@@ -68,6 +68,7 @@ public class LoadTsFileStatement extends Statement {
   private List<Boolean> isTableModel;
   private List<TsFileResource> resources;
   private List<Long> writePointCountList;
+  private boolean needDecode4TimeColumn;
 
   public LoadTsFileStatement(String filePath) throws FileNotFoundException {
     this.file = new File(filePath).getAbsoluteFile();
@@ -223,6 +224,14 @@ public boolean isGeneratedByPipe() {
     return isGeneratedByPipe;
   }
 
+  public boolean isNeedDecode4TimeColumn() {
+    return needDecode4TimeColumn;
+  }
+
+  public void enableNeedDecode4TimeColumn() {
+    this.needDecode4TimeColumn = true;
+  }
+
   public List<File> getTsFiles() {
     return tsFiles;
   }