Skip update-cache logic when loading TsFile in IoTV2Consensus (#15729)

Author: jt2594838

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/protocol/pipeconsensus/PipeConsensusReceiver.java

@@ -714,11 +714,7 @@ private TSStatus loadFileToDataRegion(String filePath, ProgressIndex progressInd
     DataRegion region =
         StorageEngine.getInstance().getDataRegion(((DataRegionId) consensusGroupId));
     if (region != null) {
-      TsFileResource resource =
-          generateTsFileResource(
-              filePath,
-              progressIndex,
-              IoTDBDescriptor.getInstance().getConfig().isCacheLastValuesForLoad());
+      TsFileResource resource = generateTsFileResource(filePath, progressIndex);
       region.loadNewTsFile(resource, true, false, true);
     } else {
       // Data region is null indicates that dr has been removed or migrated. In those cases, there
@@ -773,13 +769,13 @@ private void updateWritePointCountMetrics(long writePointCount) {
                                 dataRegion, databaseName, writePointCount, true)));
   }
 
-  private TsFileResource generateTsFileResource(
-      String filePath, ProgressIndex progressIndex, boolean cacheLastValues) throws IOException {
+  private TsFileResource generateTsFileResource(String filePath, ProgressIndex progressIndex)
+      throws IOException {
     final File tsFile = new File(filePath);
 
     final TsFileResource tsFileResource = new TsFileResource(tsFile);
     try (final TsFileSequenceReader reader = new TsFileSequenceReader(tsFile.getAbsolutePath())) {
-      TsFileResourceUtils.updateTsFileResource(reader, tsFileResource, cacheLastValues);
+      TsFileResourceUtils.updateTsFileResource(reader, tsFileResource);
     }
 
     tsFileResource.setStatus(TsFileResourceStatus.NORMAL);

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/DataRegion.java

@@ -3051,7 +3051,8 @@ public void loadNewTsFile(
 
     TsFileLastReader lastReader = null;
     LastCacheLoadStrategy lastCacheLoadStrategy = config.getLastCacheLoadStrategy();
-    if ((lastCacheLoadStrategy == LastCacheLoadStrategy.UPDATE
+    if (!isFromConsensus
+        && (lastCacheLoadStrategy == LastCacheLoadStrategy.UPDATE
             || lastCacheLoadStrategy == LastCacheLoadStrategy.UPDATE_NO_BLOB)
         && newTsFileResource.getLastValues() == null) {
       try {

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/utils/TsFileResourceUtils.java

@@ -413,9 +413,8 @@ public static boolean validateTsFileResourcesHasNoOverlap(List<TsFileResource> r
   }
 
   public static void updateTsFileResource(
-      TsFileSequenceReader reader, TsFileResource tsFileResource, boolean cacheLastValues)
-      throws IOException {
-    updateTsFileResource(reader.getAllTimeseriesMetadata(false), tsFileResource, cacheLastValues);
+      TsFileSequenceReader reader, TsFileResource tsFileResource) throws IOException {
+    updateTsFileResource(reader.getAllTimeseriesMetadata(false), tsFileResource, false);
     tsFileResource.updatePlanIndexes(reader.getMinPlanIndex());
     tsFileResource.updatePlanIndexes(reader.getMaxPlanIndex());
   }

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/wal/recover/file/AbstractTsFileRecoverPerformer.java

@@ -115,7 +115,7 @@ private void loadResourceFile() throws IOException {
   protected void reconstructResourceFile() throws IOException {
     try (TsFileSequenceReader reader =
         new TsFileSequenceReader(tsFileResource.getTsFile().getAbsolutePath())) {
-      TsFileResourceUtils.updateTsFileResource(reader, tsFileResource, false);
+      TsFileResourceUtils.updateTsFileResource(reader, tsFileResource);
     }
 
     // set progress index for pipe to avoid data loss

pom.xml

@@ -175,7 +175,7 @@
         <thrift.version>0.14.1</thrift.version>
         <xz.version>1.9</xz.version>
         <zstd-jni.version>1.5.6-3</zstd-jni.version>
-        <tsfile.version>2.1.0-250612-SNAPSHOT</tsfile.version>
+        <tsfile.version>2.1.0-250616-SNAPSHOT</tsfile.version>
     </properties>
     <!--
     if we claim dependencies in dependencyManagement, then we do not claim