(iotdb) branch rml updated: cp

[justinchen]

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

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


The following commit(s) were added to refs/heads/rml by this push:
     new 325691bf561 cp
325691bf561 is described below

commit 325691bf561de4afcf53e3a9e2b6c4a979eb9e71
Author: Caideyipi <87789683+caidey...@users.noreply.github.com>
AuthorDate: Thu Nov 27 14:26:43 2025 +0800

    cp
---
 .../main/java/org/apache/iotdb/db/storageengine/StorageEngine.java | 3 ++-
 .../org/apache/iotdb/db/storageengine/dataregion/DataRegion.java   | 6 ++++--
 .../db/storageengine/dataregion/memtable/TsFileProcessor.java      | 7 +++++--
 .../iotdb/db/service/DataNodeInternalRPCServiceImplTest.java       | 3 ++-
 4 files changed, 13 insertions(+), 6 deletions(-)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/StorageEngine.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/StorageEngine.java
index 27f840214da..c8439e02183 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/StorageEngine.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/StorageEngine.java
@@ -803,7 +803,8 @@ public class StorageEngine implements IService {
         WRITING_METRICS.removeDataRegionMemoryCostMetrics(regionId);
         WRITING_METRICS.removeFlushingMemTableStatusMetrics(regionId);
         WRITING_METRICS.removeActiveMemtableCounterMetrics(regionId);
-        FileMetrics.getInstance().deleteRegion(region.getDatabaseName(), 
region.getDataRegionIdString());
+        FileMetrics.getInstance()
+            .deleteRegion(region.getDatabaseName(), 
region.getDataRegionIdString());
       } catch (Exception e) {
         LOGGER.error(
             "Error occurs when deleting data region {}-{}",
diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/DataRegion.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/DataRegion.java
index 543a9fa8cea..068990cb6f9 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/DataRegion.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/DataRegion.java
@@ -670,7 +670,8 @@ public class DataRegion implements IDataRegionForQuery {
           || config
               .getDataRegionConsensusProtocolClass()
               .equals(ConsensusFactory.IOT_CONSENSUS_V2)) {
-        WALManager.getInstance().applyForWALNode(databaseName + 
FILE_NAME_SEPARATOR + dataRegionIdString);
+        WALManager.getInstance()
+            .applyForWALNode(databaseName + FILE_NAME_SEPARATOR + 
dataRegionIdString);
       }
       logger.info(
           "The data region {}[{}] is created successfully", databaseName, 
dataRegionIdString);
@@ -3471,7 +3472,8 @@ public class DataRegion implements IDataRegionForQuery {
     }
 
     // Listen before the tsFile is added into tsFile manager to avoid it being 
compacted
-    
PipeInsertionDataNodeListener.getInstance().listenToTsFile(dataRegionIdString, 
tsFileResource, true);
+    PipeInsertionDataNodeListener.getInstance()
+        .listenToTsFile(dataRegionIdString, tsFileResource, true);
 
     tsFileManager.add(tsFileResource, false);
 
diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/memtable/TsFileProcessor.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/memtable/TsFileProcessor.java
index f70d975a7ed..c37afbd6f26 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/memtable/TsFileProcessor.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/memtable/TsFileProcessor.java
@@ -542,7 +542,9 @@ public class TsFileProcessor {
     }
     PipeInsertionDataNodeListener.getInstance()
         .listenToInsertNode(
-            dataRegionInfo.getDataRegion().getDataRegionIdString(), 
insertTabletNode, tsFileResource);
+            dataRegionInfo.getDataRegion().getDataRegionIdString(),
+            insertTabletNode,
+            tsFileResource);
 
     int pointInserted;
     try {
@@ -1585,7 +1587,8 @@ public class TsFileProcessor {
     // Listen after "endFile" to avoid unnecessary waiting for tsFile close
     // before resource serialization to avoid missing hardlink after restart
     PipeInsertionDataNodeListener.getInstance()
-        
.listenToTsFile(dataRegionInfo.getDataRegion().getDataRegionIdString(), 
tsFileResource, false);
+        .listenToTsFile(
+            dataRegionInfo.getDataRegion().getDataRegionIdString(), 
tsFileResource, false);
 
     tsFileResource.serialize();
     FileTimeIndexCacheRecorder.getInstance().logFileTimeIndex(tsFileResource);
diff --git 
a/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/service/DataNodeInternalRPCServiceImplTest.java
 
b/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/service/DataNodeInternalRPCServiceImplTest.java
index cfd6e7e4617..c8ac2c8880e 100644
--- 
a/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/service/DataNodeInternalRPCServiceImplTest.java
+++ 
b/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/service/DataNodeInternalRPCServiceImplTest.java
@@ -94,7 +94,8 @@ public class DataNodeInternalRPCServiceImplTest {
 
     org.apache.iotdb.commons.utils.FileUtils.deleteFileOrDirectory(storageDir);
     SchemaEngine.getInstance().init();
-    SchemaEngine.getInstance().createSchemaRegion(new PartialPath("root.ln"), 
new SchemaRegionId(0));
+    SchemaEngine.getInstance()
+        .createSchemaRegion(new PartialPath("root.ln"), new SchemaRegionId(0));
     final DataRegionId id = new DataRegionId(1);
     dataRegion = new DataRegion("root.ln", "1");
     instance = DataRegionConsensusImpl.getInstance();