fix comments

Author: jt2594838

integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBLoadLastCacheIT.java

@@ -42,6 +42,7 @@
 import org.junit.After;
 import org.junit.Assert;
 import org.junit.Before;
+import org.junit.Ignore;
 import org.junit.Test;
 import org.junit.experimental.categories.Category;
 import org.junit.runner.RunWith;
@@ -107,7 +108,7 @@ public void setUp() throws Exception {
         .getConfig()
         .getDataNodeConfig()
         .setLoadLastCacheStrategy(lastCacheLoadStrategy.name())
-        .setCacheLastValuesForLoad(true);
+        .setCacheLastValuesForLoad(false);
     EnvFactory.getEnv().initClusterEnvironment();
   }
 
@@ -492,9 +493,9 @@ private void queryAll(
         int deviceNum = random.nextInt(deviceCnt);
         int measurementNum = random.nextInt(measurementCnt);
         rateLimiter.acquire();
-        long start = System.currentTimeMillis();
+        long start = System.nanoTime();
         long result = queryLastOnce(deviceNum, measurementNum, schemas, statement);
-        long timeConsumption = System.currentTimeMillis() - start;
+        long timeConsumption = System.nanoTime() - start;
         if (result == -1) {
           try {
             Thread.sleep(1000);
@@ -515,18 +516,18 @@ private void queryAll(
     System.out.printf(
         "Synchronization ends after %dms, query latency avg %fms %n",
         System.currentTimeMillis() - totalStart,
-        timeConsumptions.stream().mapToLong(i -> i).average().orElse(0.0));
+        timeConsumptions.stream().mapToLong(i -> i).average().orElse(0.0) / 1000000);
   }
 
-  // @Ignore("Performance")
+  //@Ignore("Performance")
   @Test
   public void testTableLoadPerformance() throws Exception {
     int deviceCnt = 100;
     int measurementCnt = 100;
     int blobMeasurementCnt = 10;
     int pointCnt = 100;
     int fileCnt = 1000;
-    int queryPerSec = 1000;
+    int queryPerSec = 100;
     int queryThreadsNum = 10;
 
     PerformanceSchemas schemas =

iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/iot/IoTConsensus.java

@@ -237,7 +237,7 @@ public TSStatus write(ConsensusGroupId groupId, IConsensusRequest request)
     } else if (!impl.isActive()) {
       String message =
           String.format(
-              "Peer is inactive and not ready to write request, %s, DatsaNode Id: %s",
+              "Peer is inactive and not ready to write request, %s, DataNode Id: %s",
               groupId.toString(), impl.getThisNode().getNodeId());
       return RpcUtils.getStatus(TSStatusCode.WRITE_PROCESS_REJECT, message);
     } else {

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

@@ -3012,7 +3012,7 @@ public void loadNewTsFile(
     LastCacheLoadStrategy lastCacheLoadStrategy = config.getLastCacheLoadStrategy();
     if ((lastCacheLoadStrategy == LastCacheLoadStrategy.UPDATE
             || lastCacheLoadStrategy == LastCacheLoadStrategy.UPDATE_NO_BLOB)
-        && !config.isCacheLastValuesForLoad()) {
+        && newTsFileResource.getLastValues() == null) {
       try {
         // init reader outside of lock to boost performance
         lastReader =
@@ -3106,7 +3106,6 @@ public void loadNewTsFile(
           logger.warn("Cannot close last reader after loading TsFile {}", newTsFileResource, e);
         }
       }
-      // TODO: do more precise control
     }
   }
 

iotdb-core/node-commons/src/assembly/resources/conf/iotdb-system.properties.template

@@ -2087,6 +2087,24 @@ load_active_listening_max_thread_num=0
 # Datatype: int
 load_active_listening_check_interval_seconds=5
 
+# The operation performed to LastCache when a TsFile is successfully loaded.
+# UPDATE: use the data in the TsFile to update LastCache;
+# UPDATE_NO_BLOB: similar to UPDATE, but will invalidate LastCache for blob series;
+# CLEAN_DEVICE: invalidate LastCache of devices contained in the TsFile;
+# CLEAN_ALL: clean the whole LastCache.
+last_cache_operation_on_load=UPDATE_NO_BLOB
+
+# Whether to cache last values before loading a TsFile. Only effective when
+# last_cache_operation_on_load=UPDATE_NO_BLOB or last_cache_operation_on_load=UPDATE.
+# When set to true, blob series will be ignored even with last_cache_operation_on_load=UPDATE.
+# Enabling this will increase the memory footprint during loading TsFiles.
+cache_last_values_for_load=true
+
+# When cache_last_values_for_load=true, the maximum memory that can be used to cache last values.
+# If this value is exceeded, the cached values will be abandoned and last values will be read from
+# the TsFile in a streaming manner.
+cache_last_values_memory_budget_in_byte=4194304
+
 ####################
 ### Dispatch Retry Configuration
 ####################